| Package | Description | 
|---|---|
| com.hazelcast.client.connection.nio | 
 Contains classes related to New IO for com.hazelcast.client.connection 
 | 
| com.hazelcast.client.impl | 
 Implementation classes of the com.hazelcast.client interfaces 
 | 
| com.hazelcast.client.impl.clientside | 
 Contains most of the client side HazelcastInstance implementation functionality. 
 | 
| com.hazelcast.client.impl.protocol | 
 Client protocol related private implementation classes 
 | 
| 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.cardinality | |
| 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.crdt.pncounter | |
| com.hazelcast.client.impl.protocol.task.dynamicconfig | |
| com.hazelcast.client.impl.protocol.task.executorservice | 
 Client protocol tasks implementations for ExecutorService 
 | 
| com.hazelcast.client.impl.protocol.task.executorservice.durable | |
| com.hazelcast.client.impl.protocol.task.list | 
 Client protocol tasks implementations for List 
 | 
| com.hazelcast.client.impl.protocol.task.lock | 
 Client protocol tasks implementations for ILock 
 | 
| com.hazelcast.client.impl.protocol.task.map | 
 Client protocol tasks implementations for map 
 | 
| com.hazelcast.client.impl.protocol.task.mapreduce | 
 Client protocol tasks implementations for map reduce 
 | 
| com.hazelcast.client.impl.protocol.task.multimap | 
 Client protocol tasks implementations for multi map 
 | 
| com.hazelcast.client.impl.protocol.task.queue | 
 Client protocol tasks implementations for Queue 
 | 
| com.hazelcast.client.impl.protocol.task.replicatedmap | 
 Client protocol tasks implementations for ReplicatedMap 
 | 
| com.hazelcast.client.impl.protocol.task.ringbuffer | 
 Client protocol tasks implementations for Ringbuffer 
 | 
| com.hazelcast.client.impl.protocol.task.scheduledexecutor | |
| 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.client.proxy | 
 This package contains client side proxy implementations of the different Hazelcast data structures
 and operation types 
 | 
| com.hazelcast.client.proxy.txn | 
 Contains classes related to proxy for client transactions 
 | 
| com.hazelcast.client.spi | 
 Contains classes/interfaces related to the Hazelcast client Service Provider Interface. 
 | 
| com.hazelcast.client.spi.impl | 
 Provides util classes for the Hazelcast client SPI. 
 | 
| com.hazelcast.client.spi.impl.listener | |
| com.hazelcast.flakeidgen.impl.client | |
| com.hazelcast.internal.nearcache.impl.invalidation | 
 Invalidations for Near Cache. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClientConnection.handleClientMessage(ClientMessage message)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClientEngineImpl.accept(ClientMessage clientMessage)  | 
MessageTask | 
CompositeMessageTaskFactory.create(ClientMessage clientMessage,
      Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
Throwable | 
ClientExceptionFactory.createException(ClientMessage clientMessage)  | 
<T> T | 
ClientMessageDecoder.decodeClientMessage(ClientMessage clientMessage)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClientMessage | 
ClientMessage.addFlag(short flags)
Sets the flags field value. 
 | 
ClientMessage | 
ClientMessage.copy()  | 
static ClientMessage | 
ClientMessage.create()  | 
ClientMessage | 
ClientExceptions.createExceptionMessage(Throwable throwable)  | 
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(long 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 | Field and Description | 
|---|---|
protected ClientMessage | 
AbstractMessageTask.clientMessage  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ClientMessage | 
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected ClientMessage | 
AuthenticationMessageTask.encodeAuth(byte status,
          Address thisAddress,
          String uuid,
          String ownerUuid,
          byte version,
          List<Member> cleanedUpMembers)  | 
protected abstract ClientMessage | 
AuthenticationBaseMessageTask.encodeAuth(byte status,
          Address thisAddress,
          String uuid,
          String ownerUuid,
          byte serializationVersion,
          List<Member> cleanedUpMembers)  | 
protected ClientMessage | 
AuthenticationCustomCredentialsMessageTask.encodeAuth(byte status,
          Address thisAddress,
          String uuid,
          String ownerUuid,
          byte version,
          List<Member> cleanedUpMembers)  | 
protected ClientMessage | 
PingMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddDistributedObjectListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RemovePartitionLostListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddMembershipListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
GetPartitionsMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddPartitionListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AuthenticationMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RemoveAllListenersMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CreateProxiesMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
DestroyProxyMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
GetDistributedObjectsMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RemoveDistributedObjectListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddPartitionLostListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AuthenticationCustomCredentialsMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ClientStatisticsMessageTask.encodeResponse(Object response)  | 
protected abstract ClientMessage | 
AbstractMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
DeployClassesMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
NoSuchMessageTask.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.ClientAddMembershipListenerCodec.RequestParameters | 
AddMembershipListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientGetPartitionsCodec.RequestParameters | 
GetPartitionsMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientAddPartitionListenerCodec.RequestParameters | 
AddPartitionListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientAuthenticationCodec.RequestParameters | 
AuthenticationMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveAllListenersCodec.RequestParameters | 
RemoveAllListenersMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientCreateProxiesCodec.RequestParameters | 
CreateProxiesMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientDestroyProxyCodec.RequestParameters | 
DestroyProxyMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientGetDistributedObjectsCodec.RequestParameters | 
GetDistributedObjectsMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveDistributedObjectListenerCodec.RequestParameters | 
RemoveDistributedObjectListenerMessageTask.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 com.hazelcast.client.impl.protocol.codec.ClientStatisticsCodec.RequestParameters | 
ClientStatisticsMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected abstract P | 
AbstractMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ClientDeployClassesCodec.RequestParameters | 
DeployClassesMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected ClientMessage | 
NoSuchMessageTask.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 | 
CacheAddPartitionLostListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheEventJournalSubscribeTask.encodeResponse(Object response)  | 
protected ClientMessage | 
Pre38CacheAddInvalidationListenerTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheIterateMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheSetExpiryPolicyMessageTask.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 | 
CacheAssignAndGetUuidsMessageTask.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 | 
CachePutAllMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheGetAllMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheRemoveMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheReplaceMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheAddNearCacheInvalidationListenerTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheContainsKeyMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheCreateConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheEventJournalReadTask.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 | 
CacheRemovePartitionLostListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheFetchNearCacheInvalidationMetadataTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CacheIterateEntriesMessageTask.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.CacheAddPartitionLostListenerCodec.RequestParameters | 
CacheAddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.CacheEventJournalSubscribeCodec.RequestParameters | 
CacheEventJournalSubscribeTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.CacheAddInvalidationListenerCodec.RequestParameters | 
Pre38CacheAddInvalidationListenerTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.CacheIterateCodec.RequestParameters | 
CacheIterateMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.CacheSetExpiryPolicyCodec.RequestParameters | 
CacheSetExpiryPolicyMessageTask.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.CacheAssignAndGetUuidsCodec.RequestParameters | 
CacheAssignAndGetUuidsMessageTask.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.CachePutAllCodec.RequestParameters | 
CachePutAllMessageTask.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.CacheAddNearCacheInvalidationListenerCodec.RequestParameters | 
CacheAddNearCacheInvalidationListenerTask.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.CacheEventJournalReadCodec.RequestParameters | 
CacheEventJournalReadTask.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)  | 
protected com.hazelcast.client.impl.protocol.codec.CacheRemovePartitionLostListenerCodec.RequestParameters | 
CacheRemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.CacheFetchNearCacheInvalidationMetadataCodec.RequestParameters | 
CacheFetchNearCacheInvalidationMetadataTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.CacheIterateEntriesCodec.RequestParameters | 
CacheIterateEntriesMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ClientMessage | 
CardinalityEstimatorEstimateMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
CardinalityEstimatorAddMessageTask.encodeResponse(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.hazelcast.client.impl.protocol.codec.CardinalityEstimatorEstimateCodec.RequestParameters | 
CardinalityEstimatorEstimateMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.CardinalityEstimatorAddCodec.RequestParameters | 
CardinalityEstimatorAddMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| Constructor and Description | 
|---|
CardinalityEstimatorAddMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection)  | 
CardinalityEstimatorEstimateMessageTask(ClientMessage clientMessage,
                                       Node node,
                                       Connection connection)  | 
| 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 | 
PNCounterGetConfiguredReplicaCountMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
PNCounterGetMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
PNCounterAddMessageTask.encodeResponse(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.hazelcast.client.impl.protocol.codec.PNCounterGetConfiguredReplicaCountCodec.RequestParameters | 
PNCounterGetConfiguredReplicaCountMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.PNCounterGetCodec.RequestParameters | 
PNCounterGetMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.PNCounterAddCodec.RequestParameters | 
PNCounterAddMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| Constructor and Description | 
|---|
PNCounterAddMessageTask(ClientMessage clientMessage,
                       Node node,
                       Connection connection)  | 
PNCounterGetConfiguredReplicaCountMessageTask(ClientMessage clientMessage,
                                             Node node,
                                             Connection connection)  | 
PNCounterGetMessageTask(ClientMessage clientMessage,
                       Node node,
                       Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ClientMessage | 
AddQueueConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddLockConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddEventJournalConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddCacheConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddSemaphoreConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddFlakeIdGeneratorConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddSetConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddExecutorConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddScheduledExecutorConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddRingbufferConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddMultiMapConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddReplicatedMapConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddDurableExecutorConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddMapConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddReliableTopicConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddListConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddMerkleTreeConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddCardinalityEstimatorConfigMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
AddTopicConfigMessageTask.encodeResponse(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddQueueConfigCodec.RequestParameters | 
AddQueueConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddLockConfigCodec.RequestParameters | 
AddLockConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddEventJournalConfigCodec.RequestParameters | 
AddEventJournalConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddCacheConfigCodec.RequestParameters | 
AddCacheConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddSemaphoreConfigCodec.RequestParameters | 
AddSemaphoreConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddFlakeIdGeneratorConfigCodec.RequestParameters | 
AddFlakeIdGeneratorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddSetConfigCodec.RequestParameters | 
AddSetConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddExecutorConfigCodec.RequestParameters | 
AddExecutorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddScheduledExecutorConfigCodec.RequestParameters | 
AddScheduledExecutorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddRingbufferConfigCodec.RequestParameters | 
AddRingbufferConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddMultiMapConfigCodec.RequestParameters | 
AddMultiMapConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddReplicatedMapConfigCodec.RequestParameters | 
AddReplicatedMapConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddDurableExecutorConfigCodec.RequestParameters | 
AddDurableExecutorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddMapConfigCodec.RequestParameters | 
AddMapConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddReliableTopicConfigCodec.RequestParameters | 
AddReliableTopicConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddListConfigCodec.RequestParameters | 
AddListConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddMerkleTreeConfigCodec.RequestParameters | 
AddMerkleTreeConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddCardinalityEstimatorConfigCodec.RequestParameters | 
AddCardinalityEstimatorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddTopicConfigCodec.RequestParameters | 
AddTopicConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| 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 | 
DurableExecutorRetrieveAndDisposeResultMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
DurableExecutorRetrieveResultMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
DurableExecutorIsShutdownMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
DurableExecutorShutdownMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
DurableExecutorSubmitToPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
DurableExecutorDisposeResultMessageTask.encodeResponse(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorRetrieveAndDisposeResultCodec.RequestParameters | 
DurableExecutorRetrieveAndDisposeResultMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorRetrieveResultCodec.RequestParameters | 
DurableExecutorRetrieveResultMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorIsShutdownCodec.RequestParameters | 
DurableExecutorIsShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorShutdownCodec.RequestParameters | 
DurableExecutorShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorSubmitToPartitionCodec.RequestParameters | 
DurableExecutorSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorDisposeResultCodec.RequestParameters | 
DurableExecutorDisposeResultMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| Constructor and Description | 
|---|
DurableExecutorDisposeResultMessageTask(ClientMessage clientMessage,
                                       Node node,
                                       Connection connection)  | 
DurableExecutorIsShutdownMessageTask(ClientMessage clientMessage,
                                    Node node,
                                    Connection connection)  | 
DurableExecutorRetrieveAndDisposeResultMessageTask(ClientMessage clientMessage,
                                                  Node node,
                                                  Connection connection)  | 
DurableExecutorRetrieveResultMessageTask(ClientMessage clientMessage,
                                        Node node,
                                        Connection connection)  | 
DurableExecutorShutdownMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection)  | 
DurableExecutorSubmitToPartitionMessageTask(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 | 
MapAddNearCacheInvalidationListenerMessageTask.encodeEvent(Data keyData,
           Data newValueData,
           Data oldValueData,
           Data meringValueData,
           int type,
           String uuid,
           int numberOfAffectedEntries)  | 
protected ClientMessage | 
Pre38MapAddNearCacheEntryListenerMessageTask.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 | 
MapFetchNearCacheInvalidationMetadataTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapPublisherCreateWithValueMessageTask.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 | 
MapRemoveAllMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapClearNearCacheMessageTask.encodeResponse(Object response)
Deprecated.  
  | 
protected ClientMessage | 
MapKeySetMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapDestroyCacheMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapFetchWithQueryMessageTask.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 | 
MapLoadAllMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapDeleteMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapSizeMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapPutTransientWithMaxIdleMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapAddInterceptorMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapRemoveInterceptorMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapPublisherCreateMessageTask.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 | 
MapEventJournalReadTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapGetEntryViewMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapAddNearCacheInvalidationListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapSetMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapFetchKeysMessageTask.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 | 
Pre38MapAddNearCacheEntryListenerMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapAggregateWithPredicateMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapSetTtlMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapLoadGivenKeysMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapSetWithMaxIdleMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapKeySetWithPagingPredicateMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapContainsKeyMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapPutIfAbsentMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapEventJournalSubscribeTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapPutWithMaxIdleMessageTask.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 | 
MapSubmitToKeyMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapExecuteOnKeyMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapSetReadCursorMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapFetchEntriesMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapValuesWithPagingPredicateMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapPutIfAbsentWithMaxIdleMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapReplaceIfSameMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapMadePublishableMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapAddEntryListenerToKeyMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapTryPutMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapAddListenerMessageTask.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 | 
MapProjectionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapRemoveIfSameMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapProjectionWithPredicateMessageTask.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)  | 
protected ClientMessage | 
MapAssignAndGetUuidsMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MapAggregateMessageTask.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.MapFetchNearCacheInvalidationMetadataCodec.RequestParameters | 
MapFetchNearCacheInvalidationMetadataTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryPublisherCreateWithValueCodec.RequestParameters | 
MapPublisherCreateWithValueMessageTask.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.MapRemoveAllCodec.RequestParameters | 
MapRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapClearNearCacheCodec.RequestParameters | 
MapClearNearCacheMessageTask.decodeClientMessage(ClientMessage clientMessage)
Deprecated.  
  | 
protected com.hazelcast.client.impl.protocol.codec.MapKeySetCodec.RequestParameters | 
MapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryDestroyCacheCodec.RequestParameters | 
MapDestroyCacheMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapFetchWithQueryCodec.RequestParameters | 
MapFetchWithQueryMessageTask.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.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.MapPutTransientWithMaxIdleCodec.RequestParameters | 
MapPutTransientWithMaxIdleMessageTask.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.ContinuousQueryPublisherCreateCodec.RequestParameters | 
MapPublisherCreateMessageTask.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.MapEventJournalReadCodec.RequestParameters | 
MapEventJournalReadTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapGetEntryViewCodec.RequestParameters | 
MapGetEntryViewMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters | 
MapAddNearCacheInvalidationListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapSetCodec.RequestParameters | 
MapSetMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapFetchKeysCodec.RequestParameters | 
MapFetchKeysMessageTask.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.MapAddNearCacheEntryListenerCodec.RequestParameters | 
Pre38MapAddNearCacheEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapAggregateWithPredicateCodec.RequestParameters | 
MapAggregateWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapSetTtlCodec.RequestParameters | 
MapSetTtlMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapLoadGivenKeysCodec.RequestParameters | 
MapLoadGivenKeysMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapSetWithMaxIdleCodec.RequestParameters | 
MapSetWithMaxIdleMessageTask.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.MapEventJournalSubscribeCodec.RequestParameters | 
MapEventJournalSubscribeTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapPutWithMaxIdleCodec.RequestParameters | 
MapPutWithMaxIdleMessageTask.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.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.ContinuousQuerySetReadCursorCodec.RequestParameters | 
MapSetReadCursorMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapFetchEntriesCodec.RequestParameters | 
MapFetchEntriesMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapValuesWithPagingPredicateCodec.RequestParameters | 
MapValuesWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapPutIfAbsentWithMaxIdleCodec.RequestParameters | 
MapPutIfAbsentWithMaxIdleMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapReplaceIfSameCodec.RequestParameters | 
MapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryMadePublishableCodec.RequestParameters | 
MapMadePublishableMessageTask.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.ContinuousQueryAddListenerCodec.RequestParameters | 
MapAddListenerMessageTask.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.MapProjectCodec.RequestParameters | 
MapProjectionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapRemoveIfSameCodec.RequestParameters | 
MapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapProjectWithPredicateCodec.RequestParameters | 
MapProjectionWithPredicateMessageTask.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)  | 
protected com.hazelcast.client.impl.protocol.codec.MapAssignAndGetUuidsCodec.RequestParameters | 
MapAssignAndGetUuidsMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MapAggregateCodec.RequestParameters | 
MapAggregateMessageTask.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 | 
MultiMapDeleteMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
MultiMapContainsValueMessageTask.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.MultiMapDeleteCodec.RequestParameters | 
MultiMapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsValueCodec.RequestParameters | 
MultiMapContainsValueMessageTask.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 | 
ReplicatedMapAddNearCacheListenerMessageTask.encodeEvent(Data key,
           Data newValue,
           Data oldValue,
           Data mergingValue,
           int type,
           String uuid,
           int numberOfAffectedEntries)  | 
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 | 
ReplicatedMapAddNearCacheListenerMessageTask.encodeResponse(Object response)  | 
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.ReplicatedMapAddNearCacheEntryListenerCodec.RequestParameters | 
ReplicatedMapAddNearCacheListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
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 | 
RingbufferTailSequenceMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferReadOneMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferHeadSequenceMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferRemainingCapacityMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferAddMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferAddAllMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferReadManyMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferSizeMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
RingbufferCapacityMessageTask.encodeResponse(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.hazelcast.client.impl.protocol.codec.RingbufferTailSequenceCodec.RequestParameters | 
RingbufferTailSequenceMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferReadOneCodec.RequestParameters | 
RingbufferReadOneMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferHeadSequenceCodec.RequestParameters | 
RingbufferHeadSequenceMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferRemainingCapacityCodec.RequestParameters | 
RingbufferRemainingCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferAddCodec.RequestParameters | 
RingbufferAddMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferAddAllCodec.RequestParameters | 
RingbufferAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferReadManyCodec.RequestParameters | 
RingbufferReadManyMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferSizeCodec.RequestParameters | 
RingbufferSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.RingbufferCapacityCodec.RequestParameters | 
RingbufferCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| Constructor and Description | 
|---|
RingbufferAddAllMessageTask(ClientMessage clientMessage,
                           Node node,
                           Connection connection)  | 
RingbufferAddMessageTask(ClientMessage clientMessage,
                        Node node,
                        Connection connection)  | 
RingbufferCapacityMessageTask(ClientMessage clientMessage,
                             Node node,
                             Connection connection)  | 
RingbufferHeadSequenceMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection)  | 
RingbufferReadManyMessageTask(ClientMessage clientMessage,
                             Node node,
                             Connection connection)  | 
RingbufferReadOneMessageTask(ClientMessage clientMessage,
                            Node node,
                            Connection connection)  | 
RingbufferRemainingCapacityMessageTask(ClientMessage clientMessage,
                                      Node node,
                                      Connection connection)  | 
RingbufferSizeMessageTask(ClientMessage clientMessage,
                         Node node,
                         Connection connection)  | 
RingbufferTailSequenceMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ClientMessage | 
ScheduledExecutorTaskIsDoneFromPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskDisposeFromAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorSubmitToAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorGetAllScheduledMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskIsDoneFromAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskGetDelayFromAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskGetResultFromPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskGetDelayFromPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskCancelFromPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskGetResultFromAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorShutdownMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskGetStatisticsFromAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskIsCancelledFromPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskGetStatisticsFromPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskCancelFromAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskDisposeFromPartitionMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorTaskIsCancelledFromAddressMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
ScheduledExecutorSubmitToPartitionMessageTask.encodeResponse(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsDoneFromPartitionCodec.RequestParameters | 
ScheduledExecutorTaskIsDoneFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorDisposeFromAddressCodec.RequestParameters | 
ScheduledExecutorTaskDisposeFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorSubmitToAddressCodec.RequestParameters | 
ScheduledExecutorSubmitToAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetAllScheduledFuturesCodec.RequestParameters | 
ScheduledExecutorGetAllScheduledMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsDoneFromAddressCodec.RequestParameters | 
ScheduledExecutorTaskIsDoneFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetDelayFromAddressCodec.RequestParameters | 
ScheduledExecutorTaskGetDelayFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetResultFromPartitionCodec.RequestParameters | 
ScheduledExecutorTaskGetResultFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetDelayFromPartitionCodec.RequestParameters | 
ScheduledExecutorTaskGetDelayFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorCancelFromPartitionCodec.RequestParameters | 
ScheduledExecutorTaskCancelFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetResultFromAddressCodec.RequestParameters | 
ScheduledExecutorTaskGetResultFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorShutdownCodec.RequestParameters | 
ScheduledExecutorShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetStatsFromAddressCodec.RequestParameters | 
ScheduledExecutorTaskGetStatisticsFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsCancelledFromPartitionCodec.RequestParameters | 
ScheduledExecutorTaskIsCancelledFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetStatsFromPartitionCodec.RequestParameters | 
ScheduledExecutorTaskGetStatisticsFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorCancelFromAddressCodec.RequestParameters | 
ScheduledExecutorTaskCancelFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorDisposeFromPartitionCodec.RequestParameters | 
ScheduledExecutorTaskDisposeFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsCancelledFromAddressCodec.RequestParameters | 
ScheduledExecutorTaskIsCancelledFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorSubmitToPartitionCodec.RequestParameters | 
ScheduledExecutorSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ClientMessage | 
SemaphoreReleaseMessageTask.encodeResponse(Object response)  | 
protected ClientMessage | 
SemaphoreIncreasePermitsMessageTask.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.SemaphoreIncreasePermitsCodec.RequestParameters | 
SemaphoreIncreasePermitsMessageTask.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)  | 
SemaphoreIncreasePermitsMessageTask(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 | 
|---|---|
static List<ClientMessage> | 
ClientMessageSplitter.getSubFrames(int maxFrameSize,
            ClientMessage clientMessage)
Splits a  
ClientMessage into frames of a maximum size. | 
| Modifier and Type | Method and Description | 
|---|---|
static List<ClientMessage> | 
ClientMessageSplitter.getSubFrames(int maxFrameSize,
            ClientMessage clientMessage)
Splits a  
ClientMessage into frames of a maximum size. | 
| Constructor and Description | 
|---|
ClientMessageDecoder(Connection connection,
                    Consumer<ClientMessage> dst)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected <T> T | 
ClientRingbufferProxy.invoke(ClientMessage clientMessage,
      int partitionId)  | 
| Modifier and Type | Method and Description | 
|---|---|
static ClientMessage | 
ClientTransactionUtil.invoke(ClientMessage request,
      String objectName,
      HazelcastClientInstanceImpl client,
      Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static ClientMessage | 
ClientTransactionUtil.invoke(ClientMessage request,
      String objectName,
      HazelcastClientInstanceImpl client,
      Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected <T> T | 
ClientProxy.invoke(ClientMessage clientMessage)  | 
protected <T> T | 
ClientProxy.invoke(ClientMessage clientMessage,
      Object key)  | 
protected <T> T | 
ClientProxy.invokeOnAddress(ClientMessage clientMessage,
               Address address)  | 
protected <T> T | 
ClientProxy.invokeOnPartition(ClientMessage clientMessage,
                 int partitionId)  | 
protected <T> T | 
ClientProxy.invokeOnPartitionInterruptibly(ClientMessage clientMessage,
                              int partitionId)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClientMessage | 
ListenerMessageCodec.encodeAddRequest(boolean localOnly)  | 
ClientMessage | 
ListenerMessageCodec.encodeRemoveRequest(String realRegistrationId)  | 
ClientMessage | 
ClientInvocation.getClientMessage()  | 
ClientMessage | 
ClientInvocationFuture.resolveAndThrowIfException(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
ListenerMessageCodec.decodeAddResponse(ClientMessage clientMessage)  | 
boolean | 
ListenerMessageCodec.decodeRemoveResponse(ClientMessage clientMessage)  | 
void | 
ClientResponseHandler.handle(ClientMessage message)  | 
void | 
ClientInvocation.notify(ClientMessage clientMessage)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClientInvocationFuture.andThen(ExecutionCallback<ClientMessage> callback)  | 
void | 
ClientInvocationFuture.andThen(ExecutionCallback<ClientMessage> callback,
       Executor executor)  | 
| Constructor and Description | 
|---|
ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName)
Create an invocation that will be executed on random member. 
 | 
ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                Address address)
Create an invocation that will be executed on member with given  
address. | 
ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                Connection connection)
Create an invocation that will be executed on given  
connection. | 
ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                int partitionId)
Create an invocation that will be executed on owner of  
partitionId. | 
ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                int partitionId,
                Address address,
                Connection connection)  | 
ClientInvocationFuture(ClientInvocation invocation,
                      Executor internalExecutor,
                      ClientMessage request,
                      ILogger logger,
                      CallIdSequence callIdSequence)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
AbstractClientListenerService.handleClientMessage(ClientMessage clientMessage)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected ClientMessage | 
NewIdBatchMessageTask.encodeResponse(Object response)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.hazelcast.client.impl.protocol.codec.FlakeIdGeneratorNewIdBatchCodec.RequestParameters | 
NewIdBatchMessageTask.decodeClientMessage(ClientMessage clientMessage)  | 
| Constructor and Description | 
|---|
NewIdBatchMessageTask(ClientMessage clientMessage,
                     Node node,
                     Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected abstract ClientMessage | 
AbstractBaseNearCacheInvalidationListener.encodeBatchInvalidation(String name,
                       List<Data> keys,
                       List<String> sourceUuids,
                       List<UUID> partitionUuids,
                       List<Long> sequences)  | 
protected abstract ClientMessage | 
AbstractBaseNearCacheInvalidationListener.encodeSingleInvalidation(String name,
                        Data key,
                        String sourceUuid,
                        UUID partitionUuid,
                        long sequence)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected abstract void | 
AbstractBaseNearCacheInvalidationListener.sendMessageWithOrderKey(ClientMessage clientMessage,
                       Object orderKey)  | 
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.