| Package | Description | 
|---|---|
| com.hazelcast.client | Contains classes/interfaces related to Client | 
| com.hazelcast.client.connection.nio | Contains classes related to New IO for com.hazelcast.client.connection | 
| com.hazelcast.client.impl | 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.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.internal.nearcache.impl.invalidation | Invalidations for Near Cache. | 
| com.hazelcast.nio.tcp | Contains functionality for the TCP/IP Networking for cluster members This whole package is internal and no compatibility will be provided. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ClientEngine. handleClientMessage(ClientMessage message,
                   Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ClientConnection. handleClientMessage(ClientMessage message) | 
| Modifier and Type | Method and Description | 
|---|---|
| MessageTask | CompositeMessageTaskFactory. create(ClientMessage clientMessage,
      Connection connection) | 
| <T> T | ClientMessageDecoder. decodeClientMessage(ClientMessage clientMessage) | 
| void | ClientEngineImpl. handleClientMessage(ClientMessage clientMessage,
                   Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| ClientMessage | ClientMessage. addFlag(short flags)Sets the flags field value. | 
| static ClientMessage | ClientMessage. create() | 
| ClientMessage | ClientExceptionFactory. 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) | 
| Throwable | ClientExceptionFactory. createException(ClientMessage clientMessage) | 
| 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 | 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.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 | 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.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 | 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 | 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 | 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.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.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 | 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 | MapLoadGivenKeysMessageTask. 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 | 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 | 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.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.MapLoadGivenKeysCodec.RequestParameters | MapLoadGivenKeysMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.MapKeySetWithPagingPredicateCodec.RequestParameters | MapKeySetWithPagingPredicateMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.MapContainsKeyCodec.RequestParameters | MapContainsKeyMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.MapPutIfAbsentCodec.RequestParameters | MapPutIfAbsentMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.MapEventJournalSubscribeCodec.RequestParameters | MapEventJournalSubscribeTask. 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.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 | 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.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 | SemaphoreAcquireMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SemaphoreReducePermitsMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SemaphoreAvailablePermitsMessageTasks. encodeResponse(Object response) | 
| protected ClientMessage | SemaphoreInitMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SemaphoreDrainPermitsMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SemaphoreTryAcquireMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.SemaphoreReleaseCodec.RequestParameters | SemaphoreReleaseMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SemaphoreAcquireCodec.RequestParameters | SemaphoreAcquireMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SemaphoreReducePermitsCodec.RequestParameters | SemaphoreReducePermitsMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SemaphoreAvailablePermitsCodec.RequestParameters | SemaphoreAvailablePermitsMessageTasks. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SemaphoreInitCodec.RequestParameters | SemaphoreInitMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SemaphoreDrainPermitsCodec.RequestParameters | SemaphoreDrainPermitsMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SemaphoreTryAcquireCodec.RequestParameters | SemaphoreTryAcquireMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Constructor and Description | 
|---|
| SemaphoreAcquireMessageTask(ClientMessage clientMessage,
                           Node node,
                           Connection connection) | 
| SemaphoreAvailablePermitsMessageTasks(ClientMessage clientMessage,
                                     Node node,
                                     Connection connection) | 
| SemaphoreDrainPermitsMessageTask(ClientMessage clientMessage,
                                Node node,
                                Connection connection) | 
| SemaphoreInitMessageTask(ClientMessage clientMessage,
                        Node node,
                        Connection connection) | 
| SemaphoreReducePermitsMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection) | 
| SemaphoreReleaseMessageTask(ClientMessage clientMessage,
                           Node node,
                           Connection connection) | 
| SemaphoreTryAcquireMessageTask(ClientMessage clientMessage,
                              Node node,
                              Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | SetContainsMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetAddAllMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetGetAllMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetRemoveMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetClearMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetCompareAndRemoveAllMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetRemoveListenerMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetSizeMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetAddListenerMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetContainsAllMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetAddMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetIsEmptyMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | SetCompareAndRetainAllMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.SetContainsCodec.RequestParameters | SetContainsMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetAddAllCodec.RequestParameters | SetAddAllMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetGetAllCodec.RequestParameters | SetGetAllMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetRemoveCodec.RequestParameters | SetRemoveMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetClearCodec.RequestParameters | SetClearMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRemoveAllCodec.RequestParameters | SetCompareAndRemoveAllMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetRemoveListenerCodec.RequestParameters | SetRemoveListenerMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetSizeCodec.RequestParameters | SetSizeMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetAddListenerCodec.RequestParameters | SetAddListenerMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetContainsAllCodec.RequestParameters | SetContainsAllMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetAddCodec.RequestParameters | SetAddMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetIsEmptyCodec.RequestParameters | SetIsEmptyMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRetainAllCodec.RequestParameters | SetCompareAndRetainAllMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | TopicRemoveMessageListenerMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TopicPublishMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TopicAddMessageListenerMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.TopicRemoveMessageListenerCodec.RequestParameters | TopicRemoveMessageListenerMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TopicPublishCodec.RequestParameters | TopicPublishMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec.RequestParameters | TopicAddMessageListenerMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Constructor and Description | 
|---|
| TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection) | 
| TopicPublishMessageTask(ClientMessage clientMessage,
                       Node node,
                       Connection connection) | 
| TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
                                     Node node,
                                     Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | XATransactionCreateMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | XATransactionRollbackMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | XAClearRemoteTransactionMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionCommitMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | XAFinalizeTransactionMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | XATransactionPrepareMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | XACollectTransactionsMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionRollbackMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionCreateMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | XATransactionCommitMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.XATransactionCreateCodec.RequestParameters | XATransactionCreateMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.XATransactionRollbackCodec.RequestParameters | XATransactionRollbackMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.XATransactionClearRemoteCodec.RequestParameters | XAClearRemoteTransactionMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionCommitCodec.RequestParameters | TransactionCommitMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.XATransactionFinalizeCodec.RequestParameters | XAFinalizeTransactionMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.XATransactionPrepareCodec.RequestParameters | XATransactionPrepareMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.XATransactionCollectTransactionsCodec.RequestParameters | XACollectTransactionsMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionRollbackCodec.RequestParameters | TransactionRollbackMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionCreateCodec.RequestParameters | TransactionCreateMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.XATransactionCommitCodec.RequestParameters | XATransactionCommitMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | TransactionalListAddMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalListRemoveMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalListSizeMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.TransactionalListAddCodec.RequestParameters | TransactionalListAddMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalListRemoveCodec.RequestParameters | TransactionalListRemoveMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalListSizeCodec.RequestParameters | TransactionalListSizeMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Constructor and Description | 
|---|
| TransactionalListAddMessageTask(ClientMessage clientMessage,
                               Node node,
                               Connection connection) | 
| TransactionalListRemoveMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection) | 
| TransactionalListSizeMessageTask(ClientMessage clientMessage,
                                Node node,
                                Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | TransactionalMapValuesWithPredicateMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapReplaceIfSameMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapValuesMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapKeySetMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapKeySetWithPredicateMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapContainsKeyMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapDeleteMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapSizeMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapPutIfAbsentMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapSetMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapRemoveIfSameMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapPutMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapGetMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapGetForUpdateMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapReplaceMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapRemoveMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMapIsEmptyMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesWithPredicateCodec.RequestParameters | TransactionalMapValuesWithPredicateMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceIfSameCodec.RequestParameters | TransactionalMapReplaceIfSameMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesCodec.RequestParameters | TransactionalMapValuesMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetCodec.RequestParameters | TransactionalMapKeySetMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetWithPredicateCodec.RequestParameters | TransactionalMapKeySetWithPredicateMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapContainsKeyCodec.RequestParameters | TransactionalMapContainsKeyMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapDeleteCodec.RequestParameters | TransactionalMapDeleteMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSizeCodec.RequestParameters | TransactionalMapSizeMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutIfAbsentCodec.RequestParameters | TransactionalMapPutIfAbsentMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSetCodec.RequestParameters | TransactionalMapSetMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveIfSameCodec.RequestParameters | TransactionalMapRemoveIfSameMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutCodec.RequestParameters | TransactionalMapPutMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetCodec.RequestParameters | TransactionalMapGetMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetForUpdateCodec.RequestParameters | TransactionalMapGetForUpdateMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceCodec.RequestParameters | TransactionalMapReplaceMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveCodec.RequestParameters | TransactionalMapRemoveMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMapIsEmptyCodec.RequestParameters | TransactionalMapIsEmptyMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | TransactionalMultiMapPutMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMultiMapSizeMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMultiMapGetMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMultiMapRemoveEntryMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMultiMapRemoveMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalMultiMapValueCountMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapPutCodec.RequestParameters | TransactionalMultiMapPutMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapSizeCodec.RequestParameters | TransactionalMultiMapSizeMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapGetCodec.RequestParameters | TransactionalMultiMapGetMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveEntryCodec.RequestParameters | TransactionalMultiMapRemoveEntryMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveCodec.RequestParameters | TransactionalMultiMapRemoveMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapValueCountCodec.RequestParameters | TransactionalMultiMapValueCountMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Constructor and Description | 
|---|
| TransactionalMultiMapGetMessageTask(ClientMessage clientMessage,
                                   Node node,
                                   Connection connection) | 
| TransactionalMultiMapPutMessageTask(ClientMessage clientMessage,
                                   Node node,
                                   Connection connection) | 
| TransactionalMultiMapRemoveEntryMessageTask(ClientMessage clientMessage,
                                           Node node,
                                           Connection connection) | 
| TransactionalMultiMapRemoveMessageTask(ClientMessage clientMessage,
                                      Node node,
                                      Connection connection) | 
| TransactionalMultiMapSizeMessageTask(ClientMessage clientMessage,
                                    Node node,
                                    Connection connection) | 
| TransactionalMultiMapValueCountMessageTask(ClientMessage clientMessage,
                                          Node node,
                                          Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | TransactionalQueuePollMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalQueueTakeMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalQueueSizeMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalQueuePeekMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalQueueOfferMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePollCodec.RequestParameters | TransactionalQueuePollMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueTakeCodec.RequestParameters | TransactionalQueueTakeMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueSizeCodec.RequestParameters | TransactionalQueueSizeMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePeekCodec.RequestParameters | TransactionalQueuePeekMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueOfferCodec.RequestParameters | TransactionalQueueOfferMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Constructor and Description | 
|---|
| TransactionalQueueOfferMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection) | 
| TransactionalQueuePeekMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection) | 
| TransactionalQueuePollMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection) | 
| TransactionalQueueSizeMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection) | 
| TransactionalQueueTakeMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ClientMessage | TransactionalSetRemoveMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalSetAddMessageTask. encodeResponse(Object response) | 
| protected ClientMessage | TransactionalSetSizeMessageTask. encodeResponse(Object response) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected com.hazelcast.client.impl.protocol.codec.TransactionalSetRemoveCodec.RequestParameters | TransactionalSetRemoveMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalSetAddCodec.RequestParameters | TransactionalSetAddMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| protected com.hazelcast.client.impl.protocol.codec.TransactionalSetSizeCodec.RequestParameters | TransactionalSetSizeMessageTask. decodeClientMessage(ClientMessage clientMessage) | 
| Constructor and Description | 
|---|
| TransactionalSetAddMessageTask(ClientMessage clientMessage,
                              Node node,
                              Connection connection) | 
| TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection) | 
| TransactionalSetSizeMessageTask(ClientMessage clientMessage,
                               Node node,
                               Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| static List<ClientMessage> | ClientMessageSplitter. getSubFrames(int maxFrameSize,
            ClientMessage clientMessage)Splits a  ClientMessageinto frames of a maximum size. | 
| Modifier and Type | Method and Description | 
|---|---|
| static List<ClientMessage> | ClientMessageSplitter. getSubFrames(int maxFrameSize,
            ClientMessage clientMessage)Splits a  ClientMessageinto frames of a maximum size. | 
| void | ClientMessageChannelInboundHandler.MessageHandler. handleMessage(ClientMessage message)Received message to be processed | 
| 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 | 
|---|---|
| void | ClientInvocationService. handleClientMessage(ClientMessage message,
                   Connection connection) | 
| 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 | AbstractClientInvocationService. handleClientMessage(ClientMessage message,
                   Connection connection) | 
| 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) | 
| ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                Address address) | 
| ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                Connection connection) | 
| ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                int 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,
                   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) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | MessageHandlerImpl. handleMessage(ClientMessage message) | 
| boolean | ClientChannelOutboundHandler. onWrite(ClientMessage message,
       ByteBuffer dst) | 
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.