Package | Description |
---|---|
com.hazelcast.cache.impl.client |
Hazelcast JSR-107 aka JCache implementation
Client Requests
|
com.hazelcast.client.impl.client |
This contains the Requests and other DTO's exchanged between client/server
|
com.hazelcast.client.impl.protocol.task |
Client tasks associated with requests.
|
com.hazelcast.client.impl.protocol.task.atomiclong |
Client protocol tasks implementations for AtomicLong
|
com.hazelcast.client.impl.protocol.task.atomicreference |
Client protocol tasks implementations for AtomicReference
|
com.hazelcast.client.impl.protocol.task.cache |
Client protocol tasks implementations for JCache
|
com.hazelcast.client.impl.protocol.task.condition |
Client protocol tasks implementations for Condition
|
com.hazelcast.client.impl.protocol.task.countdownlatch |
Client protocol tasks implementations for CountDownLatch
|
com.hazelcast.client.impl.protocol.task.executorservice |
Client protocol tasks implementations for ExecutorService
|
com.hazelcast.client.impl.protocol.task.list |
Client protocol tasks implementations for List
|
com.hazelcast.client.impl.protocol.task.lock |
Client protocol tasks implementations for ILock
|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.client.impl.protocol.task.mapreduce |
Client protocol tasks implementations for map reduce
|
com.hazelcast.client.impl.protocol.task.multimap |
Client protocol tasks implementations for multi map
|
com.hazelcast.client.impl.protocol.task.queue |
Client protocol tasks implementations for Queue
|
com.hazelcast.client.impl.protocol.task.replicatedmap |
Client protocol tasks implementations for ReplicatedMap
|
com.hazelcast.client.impl.protocol.task.ringbuffer |
Client protocol tasks implementations for Ringbuffer
|
com.hazelcast.client.impl.protocol.task.semaphore |
Client protocol tasks implementations for Semaphore
|
com.hazelcast.client.impl.protocol.task.set |
Client protocol tasks implementations for set
|
com.hazelcast.client.impl.protocol.task.topic |
Client protocol tasks implementations for Topic
|
com.hazelcast.client.impl.protocol.task.transaction |
Client protocol tasks implementations for Transaction related
|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.spi.impl |
Provides util classes for com.hazelcast.client
|
com.hazelcast.client.util |
This package contains some utility classes and the base implementations of the
loadbalancer implementations
|
com.hazelcast.collection.impl.collection.client | |
com.hazelcast.collection.impl.list.client | |
com.hazelcast.collection.impl.queue.client |
This package contains client requests for the IQueue.
|
com.hazelcast.concurrent.atomiclong.client |
This package contains client requests for the IAtomicLong.
This package contains all the client request object to operate on the IAtomicLong that are send by the client. |
com.hazelcast.concurrent.atomicreference.client |
This package contains client requests for the IAtomicLong.
This package contains all the client request object to operate on the IAtomicLong that are send by the client. |
com.hazelcast.concurrent.countdownlatch.client |
This package contains client requests for the ICountDownLatch.
This package contains all the client requests object to operate on the ICountDownLatch that are send by the client. |
com.hazelcast.concurrent.lock.client |
This package contains client requests for the ILock.
This package contains all the client requests object to operate on the ILock that are send by the client. |
com.hazelcast.concurrent.semaphore.client |
This package contains client requests for the ISemaphore.
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.executor.impl |
This package contains IExecutorService functionality for Hazelcast.
The IExecutorService extends the ExecutorService and provides all kinds
of additional methods related to distributed systems. |
com.hazelcast.executor.impl.client |
This package contains client requests for the IExecutorService.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.client |
Contains client requests for the
IMap |
com.hazelcast.map.impl.proxy |
Contains map proxy implementation and support classes.
|
com.hazelcast.map.impl.recordstore | |
com.hazelcast.multimap.impl.client |
Contains client requests for Hazelcast MultiMap module.
|
com.hazelcast.replicatedmap.impl.client |
This package contains classes for client communication on replicated map implementation
|
com.hazelcast.ringbuffer.impl.client | |
com.hazelcast.spi |
Provides interfaces/classes for Hazelcast SPI.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.operationservice |
Contains the
InternalOperationService API. |
com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
InternalOperationService implementation. |
com.hazelcast.topic.impl.client |
This package contains client requests for the ITopic.
|
com.hazelcast.transaction.client |
This package contains client transaction code
|
com.hazelcast.transaction.impl |
Provides implementation for Hazelcast transaction support.
|
com.hazelcast.transaction.impl.xa |
Provides implementation for Hazelcast XA transaction support.
|
com.hazelcast.util.executor |
This package contains classes related to Util.Executor
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCacheRequest |
class |
CacheContainsKeyRequest
This client request specifically calls
CacheContainsKeyOperation on the server side. |
class |
CacheEntryProcessorRequest
This client request specifically calls
CacheEntryProcessorOperation on the server side. |
class |
CacheGetAndRemoveRequest
This client request specifically calls
CacheGetAndRemoveOperation on the server side. |
class |
CacheGetAndReplaceRequest
This client request specifically calls
CacheGetAndReplaceOperation on the server side. |
class |
CacheGetConfigRequest
This client request specifically calls
CacheGetConfigOperation on the server side. |
class |
CacheGetRequest
This client request specifically calls
CacheGetOperation on the server side. |
class |
CacheIterateRequest
This client request specifically calls
CacheKeyIteratorOperation on the server side. |
class |
CacheListenerRegistrationRequest
This client request specifically calls
CacheListenerRegistrationOperation on the server side. |
class |
CacheManagementConfigRequest
This client request specifically calls
CacheManagementConfigOperation on the server side. |
class |
CachePutAllRequest
This client request that puts entries as batch into specified partition.
|
class |
CachePutIfAbsentRequest
This client request specifically calls
CachePutIfAbsentOperation on the server side. |
class |
CachePutRequest
This client request specifically calls
CachePutOperation on the server side. |
class |
CacheRemoveRequest
This client request specifically calls
CacheRemoveOperation on the server side. |
class |
CacheReplaceRequest
This client request specifically calls
CacheReplaceOperation on the server side. |
Modifier and Type | Class and Description |
---|---|
class |
ClientCreateRequest |
class |
KeyBasedClientRequest |
class |
PartitionClientRequest
Base class for partition based client request.
|
class |
TargetClientRequest |
Modifier and Type | Class and Description |
---|---|
class |
AbstractInvocationMessageTask<P> |
class |
AbstractPartitionMessageTask<P>
AbstractPartitionMessageTask
|
class |
CreateProxyMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
AtomicLongAddAndGetMessageTask |
class |
AtomicLongAlterAndGetMessageTask |
class |
AtomicLongAlterMessageTask |
class |
AtomicLongApplyMessageTask |
class |
AtomicLongCompareAndSetMessageTask |
class |
AtomicLongDecrementAndGetMessageTask |
class |
AtomicLongGetAndAddMessageTask |
class |
AtomicLongGetAndAlterMessageTask |
class |
AtomicLongGetAndIncrementMessageTask |
class |
AtomicLongGetAndSetMessageTask |
class |
AtomicLongGetMessageTask |
class |
AtomicLongIncrementAndGetMessageTask |
class |
AtomicLongSetMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
AtomicReferenceAlterAndGetMessageTask |
class |
AtomicReferenceAlterMessageTask |
class |
AtomicReferenceApplyMessageTask |
class |
AtomicReferenceClearMessageTask |
class |
AtomicReferenceCompareAndSetMessageTask |
class |
AtomicReferenceContainsMessageTask |
class |
AtomicReferenceGetAndAlterMessageTask |
class |
AtomicReferenceGetAndSetMessageTask |
class |
AtomicReferenceGetMessageTask |
class |
AtomicReferenceIsNullMessageTask |
class |
AtomicReferenceSetAndGetMessageTask |
class |
AtomicReferenceSetMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCacheMessageTask<P>
Abstract Cache request to handle InMemoryFormat which needed for operation provider
|
class |
CacheContainsKeyMessageTask
This client request specifically calls
CacheContainsKeyOperation on the server side. |
class |
CacheCreateConfigMessageTask
This client request specifically calls
CacheCreateConfigOperation on the server side. |
class |
CacheDestroyMessageTask |
class |
CacheEntryProcessorMessageTask
This client request specifically calls
CacheEntryProcessorOperation on the server side. |
class |
CacheGetAndRemoveMessageTask
This client request specifically calls
CacheGetAndRemoveOperation on the server side. |
class |
CacheGetAndReplaceMessageTask
This client request specifically calls
CacheGetAndReplaceOperation on the server side. |
class |
CacheGetConfigMessageTask
This client request specifically calls
CacheGetConfigOperation on the server side. |
class |
CacheGetMessageTask
This client request specifically calls
CacheGetOperation on the server side. |
class |
CacheIterateMessageTask
This client request specifically calls
CacheKeyIteratorOperation on the server side. |
class |
CacheListenerRegistrationMessageTask
This client request specifically calls
CacheListenerRegistrationOperation on the server side. |
class |
CacheManagementConfigMessageTask
This client request specifically calls
CacheManagementConfigOperation on the server side. |
class |
CachePutAllMessageTask
This client request specifically calls
CachePutAllOperation on the server side. |
class |
CachePutIfAbsentMessageTask
This client request specifically calls
CachePutIfAbsentOperation on the server side. |
class |
CachePutMessageTask
This client request specifically calls
CachePutOperation on the server side. |
class |
CacheRemoveMessageTask
This client request specifically calls
CacheRemoveOperation on the server side. |
class |
CacheReplaceMessageTask
This client request specifically calls
CachePutOperation on the server side. |
Modifier and Type | Class and Description |
---|---|
class |
ConditionAwaitMessageTask |
class |
ConditionBeforeAwaitMessageTask |
class |
ConditionSignalAllMessageTask |
class |
ConditionSignalMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
CountDownLatchAwaitMessageTask |
class |
CountDownLatchCountDownMessageTask |
class |
CountDownLatchGetCountMessageTask |
class |
CountDownLatchTrySetCountMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
ExecutorServiceSubmitToAddressMessageTask |
class |
ExecutorServiceSubmitToPartitionMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
ListAddAllMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_ADDALL |
class |
ListAddAllWithIndexMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_ADDALLWITHINDEX |
class |
ListAddMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_ADD |
class |
ListAddWithIndexMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_ADDWITHINDEX |
class |
ListClearMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_CLEAR |
class |
ListCompareAndRemoveAllMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_COMPAREANDREMOVEALL |
class |
ListCompareAndRetainAllMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_COMPAREANDRETAINALL |
class |
ListContainsAllMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_CONTAINSALL |
class |
ListContainsMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_CONTAINS |
class |
ListGetAllMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_GETALL |
class |
ListGetMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_GET |
class |
ListIndexOfMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_INDEXOF |
class |
ListIsEmptyMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_ADDLISTENER |
class |
ListIteratorMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_ITERATOR |
class |
ListLastIndexOfMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_LASTINDEXOF |
class |
ListListIteratorMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_LISTITERATOR |
class |
ListRemoveMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_REMOVE |
class |
ListRemoveWithIndexMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_REMOVEWITHINDEX |
class |
ListSetMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_SET |
class |
ListSizeMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_SIZE |
class |
ListSubMessageTask
Client Protocol Task for handling messages with type id:
ListMessageType.LIST_SUB |
Modifier and Type | Class and Description |
---|---|
class |
LockForceUnlockMessageTask |
class |
LockGetLockCountMessageTask |
class |
LockGetRemainingLeaseTimeMessageTask |
class |
LockIsLockedByCurrentThreadMessageTask |
class |
LockIsLockedMessageTask |
class |
LockLockMessageTask |
class |
LockTryLockMessageTask |
class |
LockUnlockMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMapPutMessageTask<P> |
class |
MapClearNearCacheMessageTask |
class |
MapContainsKeyMessageTask |
class |
MapDeleteMessageTask |
class |
MapEvictMessageTask |
class |
MapExecuteOnKeyMessageTask |
class |
MapForceUnlockMessageTask |
class |
MapGetAllMessageTask |
class |
MapGetEntryViewMessageTask |
class |
MapGetMessageTask |
class |
MapIsLockedMessageTask |
class |
MapLockMessageTask |
class |
MapPutAllMessageTask |
class |
MapPutIfAbsentMessageTask |
class |
MapPutMessageTask |
class |
MapPutTransientMessageTask |
class |
MapRemoveIfSameMessageTask |
class |
MapRemoveMessageTask |
class |
MapReplaceIfSameMessageTask |
class |
MapReplaceMessageTask |
class |
MapSetMessageTask |
class |
MapSubmitToKeyMessageTask |
class |
MapTryLockMessageTask |
class |
MapTryPutMessageTask |
class |
MapTryRemoveMessageTask |
class |
MapUnlockMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMapReduceTask<Parameters> |
class |
MapReduceForCustomMessageTask |
class |
MapReduceForListMessageTask |
class |
MapReduceForMapMessageTask |
class |
MapReduceForMultiMapMessageTask |
class |
MapReduceForSetMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
MultiMapContainsEntryMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_CONTAINSENTRY |
class |
MultiMapContainsKeyMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_CONTAINSKEY |
class |
MultiMapForceUnlockMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_FORCEUNLOCK |
class |
MultiMapGetMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_GET |
class |
MultiMapIsLockedMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_ISLOCKED |
class |
MultiMapLockMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_LOCK |
class |
MultiMapPutMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_PUT |
class |
MultiMapRemoveEntryMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_REMOVEENTRY |
class |
MultiMapRemoveMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_REMOVE |
class |
MultiMapTryLockMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_TRYLOCK |
class |
MultiMapUnlockMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_UNLOCK |
class |
MultiMapValueCountMessageTask
Client Protocol Task for handling messages with type id:
MultiMapMessageType.MULTIMAP_VALUECOUNT |
Modifier and Type | Class and Description |
---|---|
class |
QueueAddAllMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_ADDLISTENER |
class |
QueueClearMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_CLEAR |
class |
QueueCompareAndRemoveAllMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_COMPAREANDREMOVEALL |
class |
QueueCompareAndRetainAllMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_COMPAREANDRETAINALL |
class |
QueueContainsAllMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_CONTAINSALL |
class |
QueueContainsMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_CONTAINS |
class |
QueueDrainMaxSizeMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_DRAINTOMAXSIZE |
class |
QueueDrainMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_DRAINTO |
class |
QueueIsEmptyMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_ISEMPTY |
class |
QueueIteratorMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_ITERATOR |
class |
QueueOfferMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_OFFER |
class |
QueuePeekMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_PEEK |
class |
QueuePollMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_POLL |
class |
QueuePutMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_PUT |
class |
QueueRemainingCapacityMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_REMAININGCAPACITY |
class |
QueueRemoveMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_REMOVE |
class |
QueueSizeMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_SIZE |
class |
QueueTakeMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_TAKE |
Modifier and Type | Class and Description |
---|---|
class |
ReplicatedMapContainsKeyMessageTask |
class |
ReplicatedMapContainsValueMessageTask |
class |
ReplicatedMapEntrySetMessageTask |
class |
ReplicatedMapGetMessageTask |
class |
ReplicatedMapIsEmptyMessageTask |
class |
ReplicatedMapKeySetMessageTask |
class |
ReplicatedMapPutMessageTask |
class |
ReplicatedMapRemoveMessageTask |
class |
ReplicatedMapSizeMessageTask |
class |
ReplicatedMapValuesMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
RingbufferAddAllMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_OFFER |
class |
RingbufferAddMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_OFFER |
class |
RingbufferCapacityMessageTask |
class |
RingbufferHeadSequenceMessageTask |
class |
RingbufferReadManyMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_OFFER |
class |
RingbufferReadOneMessageTask
Client Protocol Task for handling messages with type id:
QueueMessageType.QUEUE_OFFER |
class |
RingbufferRemainingCapacityMessageTask |
class |
RingbufferSizeMessageTask |
class |
RingbufferTailSequenceMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
SemaphoreAcquireMessageTask |
class |
SemaphoreAvailablePermitsMessageTasks |
class |
SemaphoreDrainPermitsMessageTask |
class |
SemaphoreInitMessageTask |
class |
SemaphoreReducePermitsMessageTask |
class |
SemaphoreReleaseMessageTask |
class |
SemaphoreTryAcquireMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
SetAddAllMessageTask
SetAddAllMessageTask
|
class |
SetAddMessageTask
SetAddMessageTask
|
class |
SetClearMessageTask
SetClearMessageTask
|
class |
SetCompareAndRemoveAllMessageTask
SetCompareAndRemoveAllMessageTask
|
class |
SetCompareAndRetainAllMessageTask
SetCompareAndRetainAllMessageTask
|
class |
SetContainsAllMessageTask
SetContainsAllMessageTask
|
class |
SetContainsMessageTask
SetContainsMessageTask
|
class |
SetGetAllMessageTask
SetGetAllMessageTask
|
class |
SetIsEmptyMessageTask
SetIsEmptyMessageTask
|
class |
SetRemoveMessageTask
SetRemoveMessageTask
|
class |
SetSizeMessageTask
SetSizeMessageTask
|
Modifier and Type | Class and Description |
---|---|
class |
TopicPublishMessageTask |
Modifier and Type | Class and Description |
---|---|
class |
XAFinalizeTransactionMessageTask |
Modifier and Type | Method and Description |
---|---|
<T> void |
ClientExecutorServiceProxy.submit(Callable<T> task,
ExecutionCallback<T> callback) |
<T> void |
ClientExecutorServiceProxy.submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback) |
<T> void |
ClientExecutorServiceProxy.submit(Runnable command,
ExecutionCallback<T> callback) |
void |
ClientExecutorServiceProxy.submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback callback) |
void |
ClientMapProxy.submitToKey(K key,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
void |
NearCachedClientMapProxy.submitToKeyInternal(Data keyData,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
void |
ClientMapProxy.submitToKeyInternal(Data keyData,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
<T> void |
ClientExecutorServiceProxy.submitToKeyOwner(Callable<T> task,
Object key,
ExecutionCallback<T> callback) |
void |
ClientExecutorServiceProxy.submitToKeyOwner(Runnable command,
Object key,
ExecutionCallback callback) |
<T> void |
ClientExecutorServiceProxy.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback) |
void |
ClientExecutorServiceProxy.submitToMember(Runnable command,
Member member,
ExecutionCallback callback) |
Modifier and Type | Class and Description |
---|---|
class |
ClientInvocation
ClientInvocation handles routing of a request from client
1) Where should request be send
2) Should it be retried
3) How many times it is retried
|
Modifier and Type | Method and Description |
---|---|
void |
ClientInvocationFuture.andThen(ExecutionCallback<ClientMessage> callback) |
void |
ClientInvocationFuture.andThen(ExecutionCallback<ClientMessage> callback,
Executor executor) |
ScheduledFuture<?> |
ClientExecutionServiceImpl.schedule(Runnable command,
long delay,
TimeUnit unit,
ExecutionCallback executionCallback)
Utilized when given command needs to make a remote call.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientDelegatingFuture.andThen(ExecutionCallback<V> callback) |
void |
ClientDelegatingFuture.andThen(ExecutionCallback<V> callback,
Executor executor) |
<R> void |
ClientDelegatingFuture.andThenInternal(ExecutionCallback<R> callback) |
Modifier and Type | Class and Description |
---|---|
class |
CollectionAddAllRequest |
class |
CollectionAddRequest |
class |
CollectionClearRequest |
class |
CollectionCompareAndRemoveRequest |
class |
CollectionContainsRequest |
class |
CollectionGetAllRequest |
class |
CollectionIsEmptyRequest |
class |
CollectionRemoveRequest |
class |
CollectionRequest |
class |
CollectionSizeRequest |
Modifier and Type | Class and Description |
---|---|
class |
ListAddAllRequest |
class |
ListAddRequest |
class |
ListGetRequest |
class |
ListIndexOfRequest |
class |
ListRemoveRequest |
class |
ListSetRequest |
class |
ListSubRequest |
Modifier and Type | Class and Description |
---|---|
class |
ClearRequest
Provides the request service for
ClearOperation |
class |
CompareAndRemoveRequest
Provides the request service for
CompareAndRemoveOperation |
class |
ContainsRequest
Provides the request service for
ContainsOperation |
class |
DrainRequest
Provides the request service for
DrainOperation |
class |
IsEmptyRequest
Request to check if the Queue is empty
|
class |
IteratorRequest
Provides the request service for
IteratorOperation |
class |
OfferRequest
Provides the request service for
OfferOperation |
class |
PeekRequest
Provides the request service for
PeekOperation |
class |
PollRequest
Provides the request service for
PollOperation |
class |
QueueRequest
This class contains methods for all Queue requests
such as
ClearRequest . |
class |
RemoveRequest
Remove Request for the Queue.
|
Modifier and Type | Class and Description |
---|---|
class |
AddAndGetRequest |
class |
AtomicLongRequest |
class |
GetAndAddRequest |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAlterRequest |
class |
AlterAndGetRequest |
class |
AlterRequest |
class |
ApplyRequest |
class |
CompareAndSetRequest |
class |
GetAndAlterRequest |
class |
GetAndSetRequest |
class |
GetRequest |
class |
IsNullRequest |
class |
ModifyRequest |
class |
ReadRequest |
class |
SetRequest |
Modifier and Type | Class and Description |
---|---|
class |
AwaitRequest |
class |
CountDownRequest |
class |
GetCountRequest |
class |
SetCountRequest |
Modifier and Type | Class and Description |
---|---|
class |
AbstractIsLockedRequest |
class |
AbstractLockRequest |
class |
AbstractUnlockRequest |
class |
BeforeAwaitRequest |
class |
GetLockCountRequest |
class |
GetRemainingLeaseRequest |
class |
IsLockedRequest |
class |
LockRequest |
class |
SignalRequest |
class |
UnlockRequest |
Modifier and Type | Class and Description |
---|---|
class |
AcquireRequest |
class |
AvailableRequest |
class |
InitRequest |
class |
ReduceRequest |
class |
ReleaseRequest |
class |
SemaphoreRequest |
Modifier and Type | Method and Description |
---|---|
void |
ICompletableFuture.andThen(ExecutionCallback<V> callback)
Registers a callback that will run after the future is completed.
|
void |
ICompletableFuture.andThen(ExecutionCallback<V> callback,
Executor executor)
Registers a callback that will run with the provided executor after the future is completed.
|
<T> void |
IExecutorService.submit(Callable<T> task,
ExecutionCallback<T> callback)
Submits a task to a random member.
|
<T> void |
IExecutorService.submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback)
Submits task to a randomly selected member.
|
<T> void |
IExecutorService.submit(Runnable task,
ExecutionCallback<T> callback)
Submits a task to a random member.
|
<T> void |
IExecutorService.submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback<T> callback)
Submits a task to randomly selected members.
|
void |
IMap.submitToKey(K key,
EntryProcessor entryProcessor,
ExecutionCallback callback)
Applies the user defined EntryProcessor to the entry mapped by the key with
specified ExecutionCallback to listen event status and returns immediately.
|
<T> void |
IExecutorService.submitToKeyOwner(Callable<T> task,
Object key,
ExecutionCallback<T> callback)
Submits task to the owner of the specified key.
|
<T> void |
IExecutorService.submitToKeyOwner(Runnable task,
Object key,
ExecutionCallback<T> callback)
Submits a task to the owner of the specified key.
|
<T> void |
IExecutorService.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback)
Submits a task to the specified member.
|
<T> void |
IExecutorService.submitToMember(Runnable task,
Member member,
ExecutionCallback<T> callback)
Submits a task to the specified member.
|
Modifier and Type | Method and Description |
---|---|
<T> void |
ExecutorServiceProxy.submit(Callable<T> task,
ExecutionCallback<T> callback) |
<T> void |
ExecutorServiceProxy.submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback) |
void |
ExecutorServiceProxy.submit(Runnable task,
ExecutionCallback callback) |
void |
ExecutorServiceProxy.submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback callback) |
<T> void |
ExecutorServiceProxy.submitToKeyOwner(Callable<T> task,
Object key,
ExecutionCallback<T> callback) |
void |
ExecutorServiceProxy.submitToKeyOwner(Runnable task,
Object key,
ExecutionCallback callback) |
<T> void |
ExecutorServiceProxy.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback) |
void |
ExecutorServiceProxy.submitToMember(Runnable task,
Member member,
ExecutionCallback callback) |
Constructor and Description |
---|
ExecutionCallbackAdapter(ExecutionCallback executionCallback) |
Modifier and Type | Class and Description |
---|---|
class |
PartitionTargetCallableRequest
A
TargetClientRequest which sends a Callable task
to a specific target. |
class |
SpecificTargetCallableRequest
A
TargetClientRequest which sends
a Callable task to the given target address. |
Modifier and Type | Method and Description |
---|---|
void |
MapKeyLoader.onKeyLoad(ExecutionCallback<Boolean> callback) |
Modifier and Type | Class and Description |
---|---|
class |
MapClearNearCacheRequest |
class |
MapContainsKeyRequest |
class |
MapDeleteRequest |
class |
MapEvictRequest |
class |
MapExecuteOnKeyRequest |
class |
MapGetAllRequest |
class |
MapGetEntryViewRequest |
class |
MapGetRequest |
class |
MapIsLockedRequest |
class |
MapKeyBasedClientRequest |
class |
MapLockRequest |
class |
MapPartitionClientRequest |
class |
MapPutAllRequest |
class |
MapPutIfAbsentRequest |
class |
MapPutRequest |
class |
MapPutTransientRequest |
class |
MapRemoveIfSameRequest |
class |
MapRemoveRequest |
class |
MapReplaceIfSameRequest |
class |
MapReplaceRequest |
class |
MapSetRequest |
class |
MapTryPutRequest |
class |
MapTryRemoveRequest |
class |
MapUnlockRequest |
Modifier and Type | Method and Description |
---|---|
ICompletableFuture |
NearCachedMapProxyImpl.executeOnKeyInternal(Data key,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
void |
MapProxyImpl.submitToKey(K key,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
RecordStore.onKeyLoad(ExecutionCallback<Boolean> callback)
Register a callback for when key loading is complete
|
void |
DefaultRecordStore.onKeyLoad(ExecutionCallback<Boolean> callback) |
Modifier and Type | Class and Description |
---|---|
class |
CountRequest |
class |
GetAllRequest |
class |
KeyBasedContainsRequest
The KeyBasedContainsRequest can be used to determine if a key is available in a multimap (when value is null), or
to check if a map-entry is stored in the multimap (value not null).
|
class |
MultiMapIsLockedRequest |
class |
MultiMapKeyBasedRequest |
class |
MultiMapLockRequest |
class |
MultiMapRequest |
class |
MultiMapUnlockRequest |
class |
PutRequest |
class |
RemoveAllRequest |
Modifier and Type | Class and Description |
---|---|
class |
AddAllRequest |
class |
AddRequest |
class |
CapacityRequest |
class |
HeadSequenceRequest |
class |
ReadManyRequest |
class |
ReadOneRequest |
class |
RemainingCapacityRequest |
class |
RingbufferRequest |
class |
SizeRequest |
class |
TailSequenceRequest |
Modifier and Type | Field and Description |
---|---|
protected ExecutionCallback<Object> |
InvocationBuilder.executionCallback |
Modifier and Type | Method and Description |
---|---|
ExecutionCallback<Object> |
InvocationBuilder.getExecutionCallback()
Gets the ExecutionCallback.
|
protected ExecutionCallback |
InvocationBuilder.getTargetExecutionCallback() |
Modifier and Type | Method and Description |
---|---|
InvocationBuilder |
InvocationBuilder.setExecutionCallback(ExecutionCallback<Object> executionCallback)
Sets the ExecutionCallback.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleExecutionCallback<E>
A ExecutionCallback implementation that simplifies the implementation of the ExecutionCallback by only
needing to implement a single method.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractCompletableFuture.andThen(ExecutionCallback<V> callback) |
void |
AbstractCompletableFuture.andThen(ExecutionCallback<V> callback,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
<V> void |
InternalOperationService.asyncInvokeOnPartition(String serviceName,
Operation op,
int partitionId,
ExecutionCallback<V> callback) |
Modifier and Type | Method and Description |
---|---|
<V> void |
OperationServiceImpl.asyncInvokeOnPartition(String serviceName,
Operation op,
int partitionId,
ExecutionCallback<V> callback) |
Constructor and Description |
---|
PartitionInvocation(NodeEngineImpl nodeEngine,
String serviceName,
Operation op,
int partitionId,
int replicaIndex,
int tryCount,
long tryPauseMillis,
long callTimeout,
ExecutionCallback callback,
boolean resultDeserialized) |
TargetInvocation(NodeEngineImpl nodeEngine,
String serviceName,
Operation op,
Address target,
int tryCount,
long tryPauseMillis,
long callTimeout,
ExecutionCallback callback,
boolean resultDeserialized) |
Modifier and Type | Class and Description |
---|---|
class |
PublishRequest |
Modifier and Type | Class and Description |
---|---|
class |
FinalizeXATransactionRequest |
Modifier and Type | Method and Description |
---|---|
void |
TransactionLog.commitAsync(NodeEngine nodeEngine,
ExecutionCallback callback) |
void |
TransactionLog.rollbackAsync(NodeEngine nodeEngine,
ExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
XATransaction.commitAsync(ExecutionCallback callback) |
void |
XATransaction.rollbackAsync(ExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingFuture.andThen(ExecutionCallback<V> callback) |
void |
CompletedFuture.andThen(ExecutionCallback<V> callback) |
void |
DelegatingFuture.andThen(ExecutionCallback<V> callback,
Executor executor) |
void |
CompletedFuture.andThen(ExecutionCallback<V> callback,
Executor executor) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.