Package | Description |
---|---|
com.hazelcast.cache.impl.client |
Hazelcast JSR-107 aka JCache implementation
Client Requests
|
com.hazelcast.client.impl |
Contains most of the client side HazelcastInstance implementation functionality.
|
com.hazelcast.client.impl.client |
This contains the Requests and other DTO's exchanged between client/server
|
com.hazelcast.client.impl.protocol |
Client protocol related private implementation classes
|
com.hazelcast.client.impl.protocol.codec |
Client protocol custom codec implementations
|
com.hazelcast.client.impl.protocol.parameters | |
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.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.impl.protocol.task.transactionallist |
Client protocol tasks implementations for Transactional List
|
com.hazelcast.client.impl.protocol.task.transactionalmap |
Client protocol tasks implementations for Transactional Map
|
com.hazelcast.client.impl.protocol.task.transactionalmultimap |
Client protocol tasks implementations for Transactional MultiMap
|
com.hazelcast.client.impl.protocol.task.transactionalqueue |
Client protocol tasks implementations for Transactional Queue
|
com.hazelcast.client.impl.protocol.task.transactionalset |
Client protocol tasks implementations for Transactional Set
|
com.hazelcast.client.impl.protocol.util |
Protocol utils
|
com.hazelcast.cluster.client |
This package contains the client cluster functionality.
|
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.collection.impl.txncollection.client | |
com.hazelcast.collection.impl.txnlist.client | |
com.hazelcast.collection.impl.txnqueue.client | |
com.hazelcast.collection.impl.txnset.client | |
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.executor.impl.client |
This package contains client requests for the IExecutorService.
|
com.hazelcast.map.impl.client |
Contains client requests for the
IMap |
com.hazelcast.mapreduce.impl.client |
This package contains request and response classes for communication between cluster
members and Hazelcast native clients
|
com.hazelcast.multimap.impl.client |
Contains client requests for Hazelcast MultiMap module.
|
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.partition.client |
Contains client functionality for partition related information.
|
com.hazelcast.replicatedmap.impl.client |
This package contains classes for client communication on replicated map implementation
|
com.hazelcast.topic.impl.client |
This package contains client requests for the ITopic.
|
com.hazelcast.transaction.client |
This package contains client transaction code
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCacheRequest
Abstract cache request to handle a completion id registration.
|
class |
CacheAddEntryListenerRequest
Client request which registers an event listener on behalf of the client and delegates the received events
back to client.
|
class |
CacheAddInvalidationListenerRequest |
class |
CacheClearRequest
This client request specifically calls
CacheClearOperationFactory on the server side. |
class |
CacheContainsKeyRequest
This client request specifically calls
CacheContainsKeyOperation on the server side. |
class |
CacheCreateConfigRequest
This client request specifically calls
CacheCreateConfigOperation on the server side. |
class |
CacheDestroyRequest
This client request specifically calls
CacheDestroyOperation on the server side. |
class |
CacheEntryProcessorRequest
This client request specifically calls
CacheEntryProcessorOperation on the server side. |
class |
CacheGetAllRequest
This client request specifically calls
CacheGetAllOperationFactory 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 |
CacheLoadAllRequest
This client request specifically calls
CacheLoadAllOperationFactory on the server side. |
class |
CacheManagementConfigRequest
This client request specifically calls
CacheManagementConfigOperation on the server side. |
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 |
CacheRemoveEntryListenerRequest
Client request which unregisters the event listener on behalf of the client.
|
class |
CacheRemoveInvalidationListenerRequest
Client request which unregisters the invalidation listener on behalf of the client.
|
class |
CacheRemoveRequest
This client request specifically calls
CacheRemoveOperation on the server side. |
class |
CacheReplaceRequest
This client request specifically calls
CacheReplaceOperation on the server side. |
class |
CacheSizeRequest
This client request specifically calls
CacheSizeOperationFactory on the server side. |
Modifier and Type | Method and Description |
---|---|
void |
ClientEngineImpl.handleClientMessage(ClientMessage clientMessage,
Connection connection) |
void |
ClientEndpointImpl.sendClientMessage(ClientMessage clientMessage) |
Modifier and Type | Class and Description |
---|---|
class |
AllPartitionsClientRequest
Base class for client request that will run on all partitions.
|
class |
AuthenticationRequest
Client Authentication Request that holds credentials
|
class |
BaseClientRemoveListenerRequest |
class |
CallableClientRequest |
class |
ClientCreateRequest |
class |
ClientDestroyRequest |
class |
ClientRequest |
class |
DistributedObjectListenerRequest |
class |
GetDistributedObjectsRequest |
class |
GetMemberListRequest
Returns member list to client
|
class |
InvocationClientRequest |
class |
KeyBasedClientRequest |
class |
MultiPartitionClientRequest |
class |
MultiTargetClientRequest
Base class for client request that will be send more than one member
|
class |
PartitionClientRequest
Base class for partition based client request.
|
class |
RemoveAllListeners
When a connection does not respond to heart-beat we switch the listeners to another endpoint
If somehow connection starts to respond heart-beat we need to signal the endpoint to remove the listeners
An internal request should not be used for user calls.
|
class |
RemoveDistributedObjectListenerRequest
Client request to add a distributed object listener to a remote node.
|
class |
TargetClientRequest |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ClientMessage.addFlag(short flags)
Sets the flags field value.
|
static ClientMessage |
ClientMessage.create() |
static ClientMessage |
ClientMessage.createForDecode(ClientProtocolBuffer buffer,
int offset) |
static ClientMessage |
ClientMessage.createForEncode(ClientProtocolBuffer buffer,
int offset) |
static ClientMessage |
ClientMessage.createForEncode(int initialCapacity) |
ClientMessage |
ClientMessage.setCorrelationId(int correlationId)
Sets the correlation id field.
|
ClientMessage |
ClientMessage.setDataOffset(int dataOffset)
Sets the dataOffset field.
|
ClientMessage |
ClientMessage.setFrameLength(int length)
Sets the frame length field.
|
ClientMessage |
ClientMessage.setMessageType(int type)
Sets the message type field.
|
ClientMessage |
ClientMessage.setPartitionId(int partitionId)
Sets the partition id field.
|
ClientMessage |
ClientMessage.setVersion(short version)
Sets the version field value.
|
ClientMessage |
ClientMessage.updateFrameLength() |
Modifier and Type | Method and Description |
---|---|
MessageTask |
MessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
static Member |
MemberCodec.decode(ClientMessage clientMessage) |
static Address |
AddressCodec.decode(ClientMessage clientMessage) |
static DistributedObjectInfo |
DistributedObjectInfoCodec.decode(ClientMessage clientMessage) |
static MemberAttributeChange |
MemberAttributeChangeCodec.decode(ClientMessage clientMessage) |
static CacheEventData |
CacheEventDataCodec.decode(ClientMessage clientMessage) |
static JobPartitionState |
JobPartitionStateCodec.decode(ClientMessage clientMessage) |
static SimpleEntryView |
EntryViewCodec.decode(ClientMessage clientMessage) |
static Xid |
XIDCodec.decode(ClientMessage clientMessage) |
static void |
AddressCodec.encode(Address address,
ClientMessage clientMessage) |
static void |
CacheEventDataCodec.encode(CacheEventData cacheEventData,
ClientMessage clientMessage) |
static void |
DistributedObjectInfoCodec.encode(DistributedObjectInfo info,
ClientMessage clientMessage) |
static void |
JobPartitionStateCodec.encode(JobPartitionState jobPartitionState,
ClientMessage clientMessage) |
static void |
MemberAttributeChangeCodec.encode(MemberAttributeChange memberAttributeChange,
ClientMessage clientMessage) |
static void |
MemberCodec.encode(Member member,
ClientMessage clientMessage) |
static void |
EntryViewCodec.encode(SimpleEntryView<Data,Data> dataEntryView,
ClientMessage clientMessage) |
static void |
XIDCodec.encode(Xid xid,
ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ExceptionResultParameters.encode(String className,
String causeClassName,
String message,
String stacktrace) |
Modifier and Type | Method and Description |
---|---|
static ExceptionResultParameters |
ExceptionResultParameters.decode(ClientMessage flyweight) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
AbstractMessageTask.clientMessage |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
AuthenticationMessageTask.encodeAuth(Address thisAddress,
String uuid,
String ownerUuid) |
protected abstract ClientMessage |
AuthenticationBaseMessageTask.encodeAuth(Address thisAddress,
String uuid,
String ownerUuid) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeAuth(Address thisAddress,
String uuid,
String ownerUuid) |
protected ClientMessage |
PingMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddDistributedObjectListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetPartitionsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AuthenticationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetDistributedObjectMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveAllListenersMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DestroyProxyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RegisterMembershipListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeResponse(Object response) |
protected abstract ClientMessage |
AbstractMessageTask.encodeResponse(Object response) |
protected ClientMessage |
NoSuchMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveDistrubtedObjectListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateProxyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ClientPingCodec.RequestParameters |
PingMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters |
AddDistributedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemovePartitionLostListenerCodec.RequestParameters |
RemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientGetPartitionsCodec.RequestParameters |
GetPartitionsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAuthenticationCodec.RequestParameters |
AuthenticationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientGetDistributedObjectCodec.RequestParameters |
GetDistributedObjectMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveAllListenersCodec.RequestParameters |
RemoveAllListenersMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientDestroyProxyCodec.RequestParameters |
DestroyProxyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientMembershipListenerCodec.RequestParameters |
RegisterMembershipListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddPartitionLostListenerCodec.RequestParameters |
AddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAuthenticationCustomCodec.RequestParameters |
AuthenticationCustomCredentialsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected abstract P |
AbstractMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveDistributedObjectListenerCodec.RequestParameters |
RemoveDistrubtedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientCreateProxyCodec.RequestParameters |
CreateProxyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected void |
AbstractMessageTask.sendClientMessage(ClientMessage resultClientMessage) |
protected void |
AbstractMessageTask.sendClientMessage(Object key,
ClientMessage resultClientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AtomicLongGetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAlterAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongDecrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAddAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongCompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndIncrementMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongIncrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongSetMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndSetCodec.RequestParameters |
AtomicLongGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAlterAndGetCodec.RequestParameters |
AtomicLongAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndAddCodec.RequestParameters |
AtomicLongGetAndAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongDecrementAndGetCodec.RequestParameters |
AtomicLongDecrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongApplyCodec.RequestParameters |
AtomicLongApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAlterCodec.RequestParameters |
AtomicLongAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAddAndGetCodec.RequestParameters |
AtomicLongAddAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongCompareAndSetCodec.RequestParameters |
AtomicLongCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndIncrementCodec.RequestParameters |
AtomicLongGetAndIncrementMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetCodec.RequestParameters |
AtomicLongGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndAlterCodec.RequestParameters |
AtomicLongGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongIncrementAndGetCodec.RequestParameters |
AtomicLongIncrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongSetCodec.RequestParameters |
AtomicLongSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AtomicReferenceCompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceAlterAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetAndAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceSetAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceIsNullMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceClearMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceCompareAndSetCodec.RequestParameters |
AtomicReferenceCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceAlterAndGetCodec.RequestParameters |
AtomicReferenceAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceContainsCodec.RequestParameters |
AtomicReferenceContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetAndAlterCodec.RequestParameters |
AtomicReferenceGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceSetAndGetCodec.RequestParameters |
AtomicReferenceSetAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetAndSetCodec.RequestParameters |
AtomicReferenceGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetCodec.RequestParameters |
AtomicReferenceGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceIsNullCodec.RequestParameters |
AtomicReferenceIsNullMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceAlterCodec.RequestParameters |
AtomicReferenceAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceSetCodec.RequestParameters |
AtomicReferenceSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceApplyCodec.RequestParameters |
AtomicReferenceApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceClearCodec.RequestParameters |
AtomicReferenceClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CacheDestroyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheIterateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheListenerRegistrationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEntryProcessorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddInvalidationListenerTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheCreateConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveInvalidationListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheManagementConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllKeysMessageTask.reduce(Map<Integer,Object> map) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CacheDestroyCodec.RequestParameters |
CacheDestroyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheIterateCodec.RequestParameters |
CacheIterateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheLoadAllCodec.RequestParameters |
CacheLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetCodec.RequestParameters |
CacheGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheListenerRegistrationCodec.RequestParameters |
CacheListenerRegistrationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheEntryProcessorCodec.RequestParameters |
CacheEntryProcessorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddEntryListenerCodec.RequestParameters |
CacheAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CachePutIfAbsentCodec.RequestParameters |
CachePutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveEntryListenerCodec.RequestParameters |
CacheRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheSizeCodec.RequestParameters |
CacheSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAndReplaceCodec.RequestParameters |
CacheGetAndReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CachePutCodec.RequestParameters |
CachePutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddInvalidationListenerCodec.RequestParameters |
CacheAddInvalidationListenerTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAllCodec.RequestParameters |
CacheGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveCodec.RequestParameters |
CacheRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheReplaceCodec.RequestParameters |
CacheReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheContainsKeyCodec.RequestParameters |
CacheContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheCreateConfigCodec.RequestParameters |
CacheCreateConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetConfigCodec.RequestParameters |
CacheGetConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveInvalidationListenerCodec.RequestParameters |
CacheRemoveInvalidationListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveAllKeysCodec.RequestParameters |
CacheRemoveAllKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAndRemoveCodec.RequestParameters |
CacheGetAndRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveAllCodec.RequestParameters |
CacheRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheClearCodec.RequestParameters |
CacheClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheManagementConfigCodec.RequestParameters |
CacheManagementConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ConditionSignalAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionBeforeAwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionSignalMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionAwaitMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ConditionSignalAllCodec.RequestParameters |
ConditionSignalAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionBeforeAwaitCodec.RequestParameters |
ConditionBeforeAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionSignalCodec.RequestParameters |
ConditionSignalMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionAwaitCodec.RequestParameters |
ConditionAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
ConditionAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionBeforeAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CountDownLatchGetCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchAwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchCountDownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchTrySetCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchGetCountCodec.RequestParameters |
CountDownLatchGetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchAwaitCodec.RequestParameters |
CountDownLatchAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchCountDownCodec.RequestParameters |
CountDownLatchCountDownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchTrySetCountCodec.RequestParameters |
CountDownLatchTrySetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CountDownLatchAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchCountDownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchGetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchTrySetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ExecutorServiceIsShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToAddressMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceIsShutdownCodec.RequestParameters |
ExecutorServiceIsShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceShutdownCodec.RequestParameters |
ExecutorServiceShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceCancelOnPartitionCodec.RequestParameters |
ExecutorServiceCancelOnPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceSubmitToPartitionCodec.RequestParameters |
ExecutorServiceSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceCancelOnAddressCodec.RequestParameters |
ExecutorServiceCancelOnAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceSubmitToAddressCodec.RequestParameters |
ExecutorServiceSubmitToAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AbstractExecutorServiceCancelMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceCancelOnAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceCancelOnPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListLastIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSubMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListClearMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ListIteratorCodec.RequestParameters |
ListIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListIndexOfCodec.RequestParameters |
ListIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListGetCodec.RequestParameters |
ListGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListLastIndexOfCodec.RequestParameters |
ListLastIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddCodec.RequestParameters |
ListAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveCodec.RequestParameters |
ListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListListIteratorCodec.RequestParameters |
ListListIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListCompareAndRetainAllCodec.RequestParameters |
ListCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveListenerCodec.RequestParameters |
ListRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListIsEmptyCodec.RequestParameters |
ListIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListCompareAndRemoveAllCodec.RequestParameters |
ListCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSizeCodec.RequestParameters |
ListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListContainsCodec.RequestParameters |
ListContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddWithIndexCodec.RequestParameters |
ListAddWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSubCodec.RequestParameters |
ListSubMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddListenerCodec.RequestParameters |
ListAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListGetAllCodec.RequestParameters |
ListGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveWithIndexCodec.RequestParameters |
ListRemoveWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddAllCodec.RequestParameters |
ListAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListContainsAllCodec.RequestParameters |
ListContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddAllWithIndexCodec.RequestParameters |
ListAddAllWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSetCodec.RequestParameters |
ListSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListClearCodec.RequestParameters |
ListClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
LockIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockGetRemainingLeaseTimeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockIsLockedByCurrentThreadMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockGetLockCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.LockIsLockedCodec.RequestParameters |
LockIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockGetRemainingLeaseTimeCodec.RequestParameters |
LockGetRemainingLeaseTimeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockForceUnlockCodec.RequestParameters |
LockForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockIsLockedByCurrentThreadCodec.RequestParameters |
LockIsLockedByCurrentThreadMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockLockCodec.RequestParameters |
LockLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockUnlockCodec.RequestParameters |
LockUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockTryLockCodec.RequestParameters |
LockTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockGetLockCountCodec.RequestParameters |
LockGetLockCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
LockForceUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetLockCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetRemainingLeaseTimeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedByCurrentThreadMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockTryLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractMapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MapAddNearCacheEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapPutAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFlushMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutAsyncMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetAsyncMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutTransientMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveAsyncMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetEntryViewMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadGivenKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddNearCacheEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSubmitToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPredicateMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MapPutAllCodec.RequestParameters |
MapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerToKeyWithPredicateCodec.RequestParameters |
MapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntriesWithPagingPredicateCodec.RequestParameters |
MapEntriesWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetCodec.RequestParameters |
MapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddIndexCodec.RequestParameters |
MapAddIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapFlushCodec.RequestParameters |
MapFlushMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnKeysCodec.RequestParameters |
MapExecuteOnKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReplaceCodec.RequestParameters |
MapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetCodec.RequestParameters |
MapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetAllCodec.RequestParameters |
MapGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntriesWithPredicateCodec.RequestParameters |
MapEntriesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryLockCodec.RequestParameters |
MapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddPartitionLostListenerCodec.RequestParameters |
MapAddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapIsLockedCodec.RequestParameters |
MapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutAsyncCodec.RequestParameters |
MapPutAsyncMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLoadAllCodec.RequestParameters |
MapLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapDeleteCodec.RequestParameters |
MapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSizeCodec.RequestParameters |
MapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddInterceptorCodec.RequestParameters |
MapAddInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveInterceptorCodec.RequestParameters |
MapRemoveInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetAsyncCodec.RequestParameters |
MapGetAsyncMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLockCodec.RequestParameters |
MapLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapUnlockCodec.RequestParameters |
MapUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutTransientCodec.RequestParameters |
MapPutTransientMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapForceUnlockCodec.RequestParameters |
MapForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveAsyncCodec.RequestParameters |
MapRemoveAsyncMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetEntryViewCodec.RequestParameters |
MapGetEntryViewMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSetCodec.RequestParameters |
MapSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnAllKeysCodec.RequestParameters |
MapExecuteOnAllKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesCodec.RequestParameters |
MapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemovePartitionLostListenerCodec.RequestParameters |
MapRemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapClearCodec.RequestParameters |
MapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLoadGivenKeysCodec.RequestParameters |
MapLoadGivenKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetWithPagingPredicateCodec.RequestParameters |
MapKeySetWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapContainsKeyCodec.RequestParameters |
MapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutIfAbsentCodec.RequestParameters |
MapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetWithPredicateCodec.RequestParameters |
MapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutCodec.RequestParameters |
MapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteWithPredicateCodec.RequestParameters |
MapExecuteWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntrySetCodec.RequestParameters |
MapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapContainsValueCodec.RequestParameters |
MapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddNearCacheEntryListenerCodec.RequestParameters |
MapAddNearCacheEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSubmitToKeyCodec.RequestParameters |
MapSubmitToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnKeyCodec.RequestParameters |
MapExecuteOnKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesWithPagingPredicateCodec.RequestParameters |
MapValuesWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReplaceIfSameCodec.RequestParameters |
MapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerToKeyCodec.RequestParameters |
MapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryPutCodec.RequestParameters |
MapTryPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryRemoveCodec.RequestParameters |
MapTryRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerCodec.RequestParameters |
MapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEvictAllCodec.RequestParameters |
MapEvictAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveEntryListenerCodec.RequestParameters |
MapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveIfSameCodec.RequestParameters |
MapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerWithPredicateCodec.RequestParameters |
MapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveCodec.RequestParameters |
MapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEvictCodec.RequestParameters |
MapEvictMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapIsEmptyCodec.RequestParameters |
MapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesWithPredicateCodec.RequestParameters |
MapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapReduceCancelMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForMapMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceJobProcessInformationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForCustomMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForListMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForMultiMapMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MapReduceCancelCodec.RequestParameters |
MapReduceCancelMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForMapCodec.RequestParameters |
MapReduceForMapMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceJobProcessInformationCodec.RequestParameters |
MapReduceJobProcessInformationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForSetCodec.RequestParameters |
MapReduceForSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForCustomCodec.RequestParameters |
MapReduceForCustomMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForListCodec.RequestParameters |
MapReduceForListMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForMultiMapCodec.RequestParameters |
MapReduceForMultiMapMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AbstractMapReduceTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceCancelMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForCustomMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForListMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMultiMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceJobProcessInformationMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected abstract ClientMessage |
AbstractMultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValueCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapKeySetMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MultiMapAddEntryListenerToKeyCodec.RequestParameters |
MultiMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsValueCodec.RequestParameters |
MultiMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapCountCodec.RequestParameters |
MultiMapCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapValuesCodec.RequestParameters |
MultiMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapForceUnlockCodec.RequestParameters |
MultiMapForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveCodec.RequestParameters |
MultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapValueCountCodec.RequestParameters |
MultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapEntrySetCodec.RequestParameters |
MultiMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapUnlockCodec.RequestParameters |
MultiMapUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsKeyCodec.RequestParameters |
MultiMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapGetCodec.RequestParameters |
MultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapClearCodec.RequestParameters |
MultiMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapIsLockedCodec.RequestParameters |
MultiMapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsEntryCodec.RequestParameters |
MultiMapContainsEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapAddEntryListenerCodec.RequestParameters |
MultiMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapTryLockCodec.RequestParameters |
MultiMapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapLockCodec.RequestParameters |
MultiMapLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapSizeCodec.RequestParameters |
MultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveEntryListenerCodec.RequestParameters |
MultiMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapPutCodec.RequestParameters |
MultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveEntryCodec.RequestParameters |
MultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapKeySetCodec.RequestParameters |
MultiMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
QueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueOfferMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMaxSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemainingCapacityMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.QueuePeekCodec.RequestParameters |
QueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueSizeCodec.RequestParameters |
QueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemoveListenerCodec.RequestParameters |
QueueRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueOfferCodec.RequestParameters |
QueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueDrainToMaxSizeCodec.RequestParameters |
QueueDrainMaxSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueIteratorCodec.RequestParameters |
QueueIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemainingCapacityCodec.RequestParameters |
QueueRemainingCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueAddListenerCodec.RequestParameters |
QueueAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueIsEmptyCodec.RequestParameters |
QueueIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueContainsCodec.RequestParameters |
QueueContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueuePutCodec.RequestParameters |
QueuePutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemoveCodec.RequestParameters |
QueueRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueCompareAndRemoveAllCodec.RequestParameters |
QueueCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueAddAllCodec.RequestParameters |
QueueAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueCompareAndRetainAllCodec.RequestParameters |
QueueCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueContainsAllCodec.RequestParameters |
QueueContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueTakeCodec.RequestParameters |
QueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueClearCodec.RequestParameters |
QueueClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueuePollCodec.RequestParameters |
QueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueDrainToCodec.RequestParameters |
QueueDrainMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapPutAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapPutCodec.RequestParameters |
ReplicatedMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapSizeCodec.RequestParameters |
ReplicatedMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapRemoveEntryListenerCodec.RequestParameters |
ReplicatedMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapValuesCodec.RequestParameters |
ReplicatedMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapGetCodec.RequestParameters |
ReplicatedMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerCodec.RequestParameters |
ReplicatedMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapEntrySetCodec.RequestParameters |
ReplicatedMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapIsEmptyCodec.RequestParameters |
ReplicatedMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapKeySetCodec.RequestParameters |
ReplicatedMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapRemoveCodec.RequestParameters |
ReplicatedMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapClearCodec.RequestParameters |
ReplicatedMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerToKeyCodec.RequestParameters |
ReplicatedMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapContainsValueCodec.RequestParameters |
ReplicatedMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.RequestParameters |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapContainsKeyCodec.RequestParameters |
ReplicatedMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerWithPredicateCodec.RequestParameters |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapPutAllCodec.RequestParameters |
ReplicatedMapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
SemaphoreReleaseMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreAcquireMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreReducePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreAvailablePermitsMessageTasks.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreInitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreDrainPermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreTryAcquireMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.SemaphoreReleaseCodec.RequestParameters |
SemaphoreReleaseMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreAcquireCodec.RequestParameters |
SemaphoreAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreReducePermitsCodec.RequestParameters |
SemaphoreReducePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreAvailablePermitsCodec.RequestParameters |
SemaphoreAvailablePermitsMessageTasks.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreInitCodec.RequestParameters |
SemaphoreInitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreDrainPermitsCodec.RequestParameters |
SemaphoreDrainPermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreTryAcquireCodec.RequestParameters |
SemaphoreTryAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
SemaphoreAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreAvailablePermitsMessageTasks(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreDrainPermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreInitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReducePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReleaseMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreTryAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
SetContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRetainAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.SetContainsCodec.RequestParameters |
SetContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddAllCodec.RequestParameters |
SetAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetGetAllCodec.RequestParameters |
SetGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetRemoveCodec.RequestParameters |
SetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetClearCodec.RequestParameters |
SetClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRemoveAllCodec.RequestParameters |
SetCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetRemoveListenerCodec.RequestParameters |
SetRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetSizeCodec.RequestParameters |
SetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddListenerCodec.RequestParameters |
SetAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetContainsAllCodec.RequestParameters |
SetContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddCodec.RequestParameters |
SetAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetIsEmptyCodec.RequestParameters |
SetIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRetainAllCodec.RequestParameters |
SetCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TopicRemoveMessageListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicPublishMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicAddMessageListenerMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TopicRemoveMessageListenerCodec.RequestParameters |
TopicRemoveMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TopicPublishCodec.RequestParameters |
TopicPublishMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec.RequestParameters |
TopicAddMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicPublishMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
XATransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAClearRemoteTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCommitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAFinalizeTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionPrepareMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XACollectTransactionsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionCommitMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.XATransactionCreateCodec.RequestParameters |
XATransactionCreateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionRollbackCodec.RequestParameters |
XATransactionRollbackMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionClearRemoteCodec.RequestParameters |
XAClearRemoteTransactionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionCommitCodec.RequestParameters |
TransactionCommitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionFinalizeCodec.RequestParameters |
XAFinalizeTransactionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionPrepareCodec.RequestParameters |
XATransactionPrepareMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionCollectTransactionsCodec.RequestParameters |
XACollectTransactionsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionRollbackCodec.RequestParameters |
TransactionRollbackMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionCreateCodec.RequestParameters |
TransactionCreateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionCommitCodec.RequestParameters |
XATransactionCommitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalListAddCodec.RequestParameters |
TransactionalListAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalListRemoveCodec.RequestParameters |
TransactionalListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalListSizeCodec.RequestParameters |
TransactionalListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalListAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMapValuesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetForUpdateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapIsEmptyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesWithPredicateCodec.RequestParameters |
TransactionalMapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceIfSameCodec.RequestParameters |
TransactionalMapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesCodec.RequestParameters |
TransactionalMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetCodec.RequestParameters |
TransactionalMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetWithPredicateCodec.RequestParameters |
TransactionalMapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapContainsKeyCodec.RequestParameters |
TransactionalMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapDeleteCodec.RequestParameters |
TransactionalMapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSizeCodec.RequestParameters |
TransactionalMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutIfAbsentCodec.RequestParameters |
TransactionalMapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSetCodec.RequestParameters |
TransactionalMapSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveIfSameCodec.RequestParameters |
TransactionalMapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutCodec.RequestParameters |
TransactionalMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetCodec.RequestParameters |
TransactionalMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetForUpdateCodec.RequestParameters |
TransactionalMapGetForUpdateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceCodec.RequestParameters |
TransactionalMapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveCodec.RequestParameters |
TransactionalMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapIsEmptyCodec.RequestParameters |
TransactionalMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapValueCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapPutCodec.RequestParameters |
TransactionalMultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapSizeCodec.RequestParameters |
TransactionalMultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapGetCodec.RequestParameters |
TransactionalMultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveEntryCodec.RequestParameters |
TransactionalMultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveCodec.RequestParameters |
TransactionalMultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapValueCountCodec.RequestParameters |
TransactionalMultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalMultiMapGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapPutMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveEntryMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapValueCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalQueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueOfferMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePollCodec.RequestParameters |
TransactionalQueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueTakeCodec.RequestParameters |
TransactionalQueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueSizeCodec.RequestParameters |
TransactionalQueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePeekCodec.RequestParameters |
TransactionalQueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueOfferCodec.RequestParameters |
TransactionalQueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalQueueOfferMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePeekMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePollMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueTakeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalSetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetRemoveCodec.RequestParameters |
TransactionalSetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetAddCodec.RequestParameters |
TransactionalSetAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetSizeCodec.RequestParameters |
TransactionalSetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalSetAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
ClientMessageBuilder.MessageHandler.handleMessage(ClientMessage message)
Received message to be processed
|
Modifier and Type | Class and Description |
---|---|
class |
AddMembershipListenerRequest |
class |
ClientPingRequest |
class |
RegisterMembershipListenerRequest |
Modifier and Type | Class and Description |
---|---|
class |
CollectionAddAllRequest |
class |
CollectionAddListenerRequest
this class is used to attach a listener to node for collections
|
class |
CollectionAddRequest |
class |
CollectionClearRequest |
class |
CollectionCompareAndRemoveRequest |
class |
CollectionContainsRequest |
class |
CollectionGetAllRequest |
class |
CollectionIsEmptyRequest |
class |
CollectionRemoveListenerRequest |
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 |
AddAllRequest
Provides the request service for
AddAllOperation |
class |
AddListenerRequest
this class is used to attach a listener to targeted node which sends back the events to client for a queue
|
class |
CompareAndRemoveRequest
Provides the request service for
CompareAndRemoveOperation |
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 |
RemainingCapacityRequest
Request for remaining capacity of Queue.
|
class |
RemoveListenerRequest
Remove listener request belong to the Queue item.
|
Modifier and Type | Class and Description |
---|---|
class |
TxnCollectionRequest |
Modifier and Type | Class and Description |
---|---|
class |
TxnListAddRequest |
class |
TxnListRemoveRequest |
class |
TxnListSizeRequest |
Modifier and Type | Class and Description |
---|---|
class |
TxnOfferRequest
Request for transactional offer operation.
|
class |
TxnPeekRequest
Request for transactional peek operation.
|
class |
TxnPollRequest
Request for transactional poll operation.
|
class |
TxnSizeRequest
Request for size of the Transactional Queue.
|
Modifier and Type | Class and Description |
---|---|
class |
TxnSetAddRequest |
class |
TxnSetRemoveRequest |
class |
TxnSetSizeRequest |
Modifier and Type | Class and Description |
---|---|
class |
AddAndGetRequest |
class |
AtomicLongRequest |
class |
CompareAndSetRequest |
class |
GetAndAddRequest |
class |
GetAndSetRequest |
class |
SetRequest |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAlterRequest |
class |
AlterAndGetRequest |
class |
AlterRequest |
class |
ApplyRequest |
class |
GetAndAlterRequest |
class |
GetRequest |
class |
IsNullRequest |
class |
ModifyRequest |
class |
ReadRequest |
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 | Class and Description |
---|---|
class |
CancellationRequest |
class |
IsShutdownRequest |
class |
PartitionTargetCallableRequest
A
TargetClientRequest which sends a Callable task
to a specific target. |
class |
ShutdownRequest |
class |
SpecificTargetCallableRequest
A
TargetClientRequest which sends
a Callable task to the given target address. |
Modifier and Type | Class and Description |
---|---|
class |
ClientCancellationRequest
This class is used to request a map reduce job cancellation on the job owning
node from the emitting client.
|
class |
ClientJobProcessInformationRequest
This class is used to retrieve current processed records and other statistics from
emitting client to the job owning node.
|
class |
ClientMapReduceRequest<KeyIn,ValueIn>
This class is used to prepare and start a map reduce job emitted by a client
on a random node in the cluster (making it the job owner).
|
Modifier and Type | Method and Description |
---|---|
void |
NodeIOService.handleClientMessage(ClientMessage cm,
Connection connection) |
void |
IOService.handleClientMessage(ClientMessage cm,
Connection connection) |
Modifier and Type | Class and Description |
---|---|
class |
AddPartitionLostListenerRequest |
class |
GetPartitionsRequest |
class |
RemovePartitionLostListenerRequest |
Modifier and Type | Class and Description |
---|---|
class |
AddMessageListenerRequest |
class |
PublishRequest |
class |
RemoveMessageListenerRequest |
Modifier and Type | Class and Description |
---|---|
class |
BaseTransactionRequest |
class |
BaseXATransactionRequest |
class |
ClearRemoteTransactionRequest |
class |
CollectXATransactionsRequest |
class |
CommitTransactionRequest |
class |
CommitXATransactionRequest |
class |
CreateTransactionRequest |
class |
CreateXATransactionRequest |
class |
FinalizeXATransactionRequest |
class |
PrepareXATransactionRequest |
class |
RollbackTransactionRequest |
class |
RollbackXATransactionRequest |
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.