Package | Description |
---|---|
com.hazelcast.client.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
com.hazelcast.client.impl |
Implementation classes of the com.hazelcast.client interfaces
|
com.hazelcast.client.impl.clientside |
Contains most of the client side HazelcastInstance implementation functionality.
|
com.hazelcast.client.impl.protocol |
Client protocol related private implementation classes
|
com.hazelcast.client.impl.protocol.task |
Client tasks associated with requests.
|
com.hazelcast.client.impl.protocol.task.atomiclong |
Client protocol tasks implementations for AtomicLong
|
com.hazelcast.client.impl.protocol.task.atomicreference |
Client protocol tasks implementations for AtomicReference
|
com.hazelcast.client.impl.protocol.task.cache |
Client protocol tasks implementations for JCache
|
com.hazelcast.client.impl.protocol.task.cardinality | |
com.hazelcast.client.impl.protocol.task.condition |
Client protocol tasks implementations for Condition
|
com.hazelcast.client.impl.protocol.task.countdownlatch |
Client protocol tasks implementations for CountDownLatch
|
com.hazelcast.client.impl.protocol.task.crdt.pncounter | |
com.hazelcast.client.impl.protocol.task.dynamicconfig | |
com.hazelcast.client.impl.protocol.task.executorservice |
Client protocol tasks implementations for ExecutorService
|
com.hazelcast.client.impl.protocol.task.executorservice.durable | |
com.hazelcast.client.impl.protocol.task.list |
Client protocol tasks implementations for List
|
com.hazelcast.client.impl.protocol.task.lock |
Client protocol tasks implementations for ILock
|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.client.impl.protocol.task.mapreduce |
Client protocol tasks implementations for map reduce
|
com.hazelcast.client.impl.protocol.task.multimap |
Client protocol tasks implementations for multi map
|
com.hazelcast.client.impl.protocol.task.queue |
Client protocol tasks implementations for Queue
|
com.hazelcast.client.impl.protocol.task.replicatedmap |
Client protocol tasks implementations for ReplicatedMap
|
com.hazelcast.client.impl.protocol.task.ringbuffer |
Client protocol tasks implementations for Ringbuffer
|
com.hazelcast.client.impl.protocol.task.scheduledexecutor | |
com.hazelcast.client.impl.protocol.task.semaphore |
Client protocol tasks implementations for Semaphore
|
com.hazelcast.client.impl.protocol.task.set |
Client protocol tasks implementations for set
|
com.hazelcast.client.impl.protocol.task.topic |
Client protocol tasks implementations for Topic
|
com.hazelcast.client.impl.protocol.task.transaction |
Client protocol tasks implementations for Transaction related
|
com.hazelcast.client.impl.protocol.task.transactionallist |
Client protocol tasks implementations for Transactional List
|
com.hazelcast.client.impl.protocol.task.transactionalmap |
Client protocol tasks implementations for Transactional Map
|
com.hazelcast.client.impl.protocol.task.transactionalmultimap |
Client protocol tasks implementations for Transactional MultiMap
|
com.hazelcast.client.impl.protocol.task.transactionalqueue |
Client protocol tasks implementations for Transactional Queue
|
com.hazelcast.client.impl.protocol.task.transactionalset |
Client protocol tasks implementations for Transactional Set
|
com.hazelcast.client.impl.protocol.util |
Protocol utils
|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.proxy.txn |
Contains classes related to proxy for client transactions
|
com.hazelcast.client.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
com.hazelcast.client.spi.impl |
Provides util classes for the Hazelcast client SPI.
|
com.hazelcast.client.spi.impl.listener | |
com.hazelcast.cp.internal.client | |
com.hazelcast.cp.internal.datastructures.atomiclong.client |
Client protocol tasks for the Raft-based AtomicLong implementation
|
com.hazelcast.cp.internal.datastructures.atomicref.client |
Client protocol tasks for the Raft-based AtomicReference implementation
|
com.hazelcast.cp.internal.datastructures.countdownlatch.client |
Client protocol tasks for the Raft-based CountDownLatch implementation
|
com.hazelcast.cp.internal.datastructures.lock.client |
Client protocol tasks for the Raft-based Lock implementation
|
com.hazelcast.cp.internal.datastructures.semaphore.client |
Client protocol tasks for the Raft-based Semaphore implementation
|
com.hazelcast.cp.internal.datastructures.spi.client |
Contains utilities for creating Raft groups and fetching Raft group ids
from clients
|
com.hazelcast.cp.internal.session.client |
Client protocol tasks for the Raft-based Session implementation
|
com.hazelcast.flakeidgen.impl.client | |
com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientConnection.handleClientMessage(ClientMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
ClientEngineImpl.accept(ClientMessage clientMessage) |
void |
NoOpClientEngine.accept(ClientMessage clientMessage) |
MessageTask |
CompositeMessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
Throwable |
ClientExceptionFactory.createException(ClientMessage clientMessage) |
<T> T |
ClientMessageDecoder.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ClientMessage.addFlag(short flags)
Sets the flags field value.
|
ClientMessage |
ClientMessage.copy() |
static ClientMessage |
ClientMessage.create() |
ClientMessage |
ClientExceptions.createExceptionMessage(Throwable throwable) |
static ClientMessage |
ClientMessage.createForDecode(ClientProtocolBuffer buffer,
int offset) |
static ClientMessage |
ClientMessage.createForEncode(ClientProtocolBuffer buffer,
int offset) |
static ClientMessage |
ClientMessage.createForEncode(int initialCapacity) |
ClientMessage |
ClientMessage.setCorrelationId(long correlationId)
Sets the correlation ID field.
|
ClientMessage |
ClientMessage.setDataOffset(int dataOffset)
Sets the dataOffset field.
|
ClientMessage |
ClientMessage.setFrameLength(int length)
Sets the frame length field.
|
ClientMessage |
ClientMessage.setMessageType(int type)
Sets the message type field.
|
ClientMessage |
ClientMessage.setPartitionId(int partitionId)
Sets the partition ID field.
|
ClientMessage |
ClientMessage.setVersion(short version)
Sets the version field value.
|
ClientMessage |
ClientMessage.updateFrameLength() |
Modifier and Type | Method and Description |
---|---|
MessageTask |
MessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
AbstractMessageTask.clientMessage |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
AuthenticationMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte version,
List<Member> cleanedUpMembers,
int partitionCount,
String clusterId) |
protected abstract ClientMessage |
AuthenticationBaseMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte serializationVersion,
List<Member> cleanedUpMembers,
int partitionCount,
String clusterId) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte version,
List<Member> cleanedUpMembers,
int partitionCount,
String clusterId) |
protected ClientMessage |
PingMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddDistributedObjectListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddMembershipListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetPartitionsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddPartitionListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AuthenticationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveAllListenersMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateProxiesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DestroyProxyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetDistributedObjectsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveDistributedObjectListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ClientStatisticsMessageTask.encodeResponse(Object response) |
protected abstract ClientMessage |
AbstractMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DeployClassesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
NoSuchMessageTask.encodeResponse(Object response) |
protected ClientMessage |
IsFailoverSupportedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateProxyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ClientPingCodec.RequestParameters |
PingMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters |
AddDistributedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemovePartitionLostListenerCodec.RequestParameters |
RemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddMembershipListenerCodec.RequestParameters |
AddMembershipListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientGetPartitionsCodec.RequestParameters |
GetPartitionsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddPartitionListenerCodec.RequestParameters |
AddPartitionListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAuthenticationCodec.RequestParameters |
AuthenticationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveAllListenersCodec.RequestParameters |
RemoveAllListenersMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientCreateProxiesCodec.RequestParameters |
CreateProxiesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientDestroyProxyCodec.RequestParameters |
DestroyProxyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientGetDistributedObjectsCodec.RequestParameters |
GetDistributedObjectsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveDistributedObjectListenerCodec.RequestParameters |
RemoveDistributedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddPartitionLostListenerCodec.RequestParameters |
AddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAuthenticationCustomCodec.RequestParameters |
AuthenticationCustomCredentialsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientStatisticsCodec.RequestParameters |
ClientStatisticsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected abstract P |
AbstractMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientDeployClassesCodec.RequestParameters |
DeployClassesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientIsFailoverSupportedCodec.RequestParameters |
IsFailoverSupportedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientCreateProxyCodec.RequestParameters |
CreateProxyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected void |
AbstractMessageTask.sendClientMessage(ClientMessage resultClientMessage) |
protected void |
AbstractMessageTask.sendClientMessage(Object key,
ClientMessage resultClientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AtomicLongGetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAlterAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongDecrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAddAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongCompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndIncrementMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongIncrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongSetMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndSetCodec.RequestParameters |
AtomicLongGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAlterAndGetCodec.RequestParameters |
AtomicLongAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndAddCodec.RequestParameters |
AtomicLongGetAndAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongDecrementAndGetCodec.RequestParameters |
AtomicLongDecrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongApplyCodec.RequestParameters |
AtomicLongApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAlterCodec.RequestParameters |
AtomicLongAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAddAndGetCodec.RequestParameters |
AtomicLongAddAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongCompareAndSetCodec.RequestParameters |
AtomicLongCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndIncrementCodec.RequestParameters |
AtomicLongGetAndIncrementMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetCodec.RequestParameters |
AtomicLongGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndAlterCodec.RequestParameters |
AtomicLongGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongIncrementAndGetCodec.RequestParameters |
AtomicLongIncrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongSetCodec.RequestParameters |
AtomicLongSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AtomicReferenceCompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceAlterAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetAndAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceSetAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceIsNullMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceClearMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceCompareAndSetCodec.RequestParameters |
AtomicReferenceCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceAlterAndGetCodec.RequestParameters |
AtomicReferenceAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceContainsCodec.RequestParameters |
AtomicReferenceContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetAndAlterCodec.RequestParameters |
AtomicReferenceGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceSetAndGetCodec.RequestParameters |
AtomicReferenceSetAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetAndSetCodec.RequestParameters |
AtomicReferenceGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetCodec.RequestParameters |
AtomicReferenceGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceIsNullCodec.RequestParameters |
AtomicReferenceIsNullMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceAlterCodec.RequestParameters |
AtomicReferenceAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceSetCodec.RequestParameters |
AtomicReferenceSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceApplyCodec.RequestParameters |
AtomicReferenceApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceClearCodec.RequestParameters |
AtomicReferenceClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CacheDestroyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEventJournalSubscribeTask.encodeResponse(Object response) |
protected ClientMessage |
Pre38CacheAddInvalidationListenerTask.encodeResponse(Object response) |
protected ClientMessage |
CacheIterateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheSetExpiryPolicyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheListenerRegistrationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEntryProcessorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAssignAndGetUuidsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddNearCacheInvalidationListenerTask.encodeResponse(Object response) |
protected ClientMessage |
CacheContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheCreateConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEventJournalReadTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveInvalidationListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheManagementConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheFetchNearCacheInvalidationMetadataTask.encodeResponse(Object response) |
protected ClientMessage |
CacheIterateEntriesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllKeysMessageTask.reduce(Map<Integer,Object> map) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CacheDestroyCodec.RequestParameters |
CacheDestroyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddPartitionLostListenerCodec.RequestParameters |
CacheAddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheEventJournalSubscribeCodec.RequestParameters |
CacheEventJournalSubscribeTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddInvalidationListenerCodec.RequestParameters |
Pre38CacheAddInvalidationListenerTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheIterateCodec.RequestParameters |
CacheIterateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheSetExpiryPolicyCodec.RequestParameters |
CacheSetExpiryPolicyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheLoadAllCodec.RequestParameters |
CacheLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetCodec.RequestParameters |
CacheGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheListenerRegistrationCodec.RequestParameters |
CacheListenerRegistrationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheEntryProcessorCodec.RequestParameters |
CacheEntryProcessorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddEntryListenerCodec.RequestParameters |
CacheAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CachePutIfAbsentCodec.RequestParameters |
CachePutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAssignAndGetUuidsCodec.RequestParameters |
CacheAssignAndGetUuidsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveEntryListenerCodec.RequestParameters |
CacheRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheSizeCodec.RequestParameters |
CacheSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAndReplaceCodec.RequestParameters |
CacheGetAndReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CachePutCodec.RequestParameters |
CachePutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CachePutAllCodec.RequestParameters |
CachePutAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAllCodec.RequestParameters |
CacheGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveCodec.RequestParameters |
CacheRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheReplaceCodec.RequestParameters |
CacheReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddNearCacheInvalidationListenerCodec.RequestParameters |
CacheAddNearCacheInvalidationListenerTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheContainsKeyCodec.RequestParameters |
CacheContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheCreateConfigCodec.RequestParameters |
CacheCreateConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheEventJournalReadCodec.RequestParameters |
CacheEventJournalReadTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetConfigCodec.RequestParameters |
CacheGetConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveInvalidationListenerCodec.RequestParameters |
CacheRemoveInvalidationListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveAllKeysCodec.RequestParameters |
CacheRemoveAllKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAndRemoveCodec.RequestParameters |
CacheGetAndRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveAllCodec.RequestParameters |
CacheRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheClearCodec.RequestParameters |
CacheClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheManagementConfigCodec.RequestParameters |
CacheManagementConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemovePartitionLostListenerCodec.RequestParameters |
CacheRemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheFetchNearCacheInvalidationMetadataCodec.RequestParameters |
CacheFetchNearCacheInvalidationMetadataTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheIterateEntriesCodec.RequestParameters |
CacheIterateEntriesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CardinalityEstimatorEstimateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CardinalityEstimatorAddMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CardinalityEstimatorEstimateCodec.RequestParameters |
CardinalityEstimatorEstimateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CardinalityEstimatorAddCodec.RequestParameters |
CardinalityEstimatorAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CardinalityEstimatorAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CardinalityEstimatorEstimateMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ConditionSignalAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionBeforeAwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionSignalMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionAwaitMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ConditionSignalAllCodec.RequestParameters |
ConditionSignalAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionBeforeAwaitCodec.RequestParameters |
ConditionBeforeAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionSignalCodec.RequestParameters |
ConditionSignalMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionAwaitCodec.RequestParameters |
ConditionAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
ConditionAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionBeforeAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CountDownLatchGetCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchAwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchCountDownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchTrySetCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchGetCountCodec.RequestParameters |
CountDownLatchGetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchAwaitCodec.RequestParameters |
CountDownLatchAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchCountDownCodec.RequestParameters |
CountDownLatchCountDownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchTrySetCountCodec.RequestParameters |
CountDownLatchTrySetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CountDownLatchAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchCountDownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchGetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchTrySetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
PNCounterGetConfiguredReplicaCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
PNCounterGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
PNCounterAddMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.PNCounterGetConfiguredReplicaCountCodec.RequestParameters |
PNCounterGetConfiguredReplicaCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.PNCounterGetCodec.RequestParameters |
PNCounterGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.PNCounterAddCodec.RequestParameters |
PNCounterAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
PNCounterAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
PNCounterGetConfiguredReplicaCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
PNCounterGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AddQueueConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddLockConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddEventJournalConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddCacheConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddSemaphoreConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddFlakeIdGeneratorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddSetConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddPNCounterConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddExecutorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddScheduledExecutorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddRingbufferConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddMultiMapConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddReplicatedMapConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddDurableExecutorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddMapConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddReliableTopicConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddListConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddMerkleTreeConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddCardinalityEstimatorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddTopicConfigMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddQueueConfigCodec.RequestParameters |
AddQueueConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddLockConfigCodec.RequestParameters |
AddLockConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddEventJournalConfigCodec.RequestParameters |
AddEventJournalConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddCacheConfigCodec.RequestParameters |
AddCacheConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddSemaphoreConfigCodec.RequestParameters |
AddSemaphoreConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddFlakeIdGeneratorConfigCodec.RequestParameters |
AddFlakeIdGeneratorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddSetConfigCodec.RequestParameters |
AddSetConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddPNCounterConfigCodec.RequestParameters |
AddPNCounterConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddExecutorConfigCodec.RequestParameters |
AddExecutorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddScheduledExecutorConfigCodec.RequestParameters |
AddScheduledExecutorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddRingbufferConfigCodec.RequestParameters |
AddRingbufferConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddMultiMapConfigCodec.RequestParameters |
AddMultiMapConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddReplicatedMapConfigCodec.RequestParameters |
AddReplicatedMapConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddDurableExecutorConfigCodec.RequestParameters |
AddDurableExecutorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddMapConfigCodec.RequestParameters |
AddMapConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddReliableTopicConfigCodec.RequestParameters |
AddReliableTopicConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddListConfigCodec.RequestParameters |
AddListConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddMerkleTreeConfigCodec.RequestParameters |
AddMerkleTreeConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddCardinalityEstimatorConfigCodec.RequestParameters |
AddCardinalityEstimatorConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DynamicConfigAddTopicConfigCodec.RequestParameters |
AddTopicConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ExecutorServiceIsShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToAddressMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceIsShutdownCodec.RequestParameters |
ExecutorServiceIsShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceShutdownCodec.RequestParameters |
ExecutorServiceShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceCancelOnPartitionCodec.RequestParameters |
ExecutorServiceCancelOnPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceSubmitToPartitionCodec.RequestParameters |
ExecutorServiceSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceCancelOnAddressCodec.RequestParameters |
ExecutorServiceCancelOnAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceSubmitToAddressCodec.RequestParameters |
ExecutorServiceSubmitToAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
ExecutorServiceCancelOnAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceCancelOnPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
DurableExecutorRetrieveAndDisposeResultMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorRetrieveResultMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorIsShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorSubmitToPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorDisposeResultMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorRetrieveAndDisposeResultCodec.RequestParameters |
DurableExecutorRetrieveAndDisposeResultMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorRetrieveResultCodec.RequestParameters |
DurableExecutorRetrieveResultMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorIsShutdownCodec.RequestParameters |
DurableExecutorIsShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorShutdownCodec.RequestParameters |
DurableExecutorShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorSubmitToPartitionCodec.RequestParameters |
DurableExecutorSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.DurableExecutorDisposeResultCodec.RequestParameters |
DurableExecutorDisposeResultMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
DurableExecutorDisposeResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorRetrieveAndDisposeResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorRetrieveResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListLastIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSubMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListClearMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ListIteratorCodec.RequestParameters |
ListIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListIndexOfCodec.RequestParameters |
ListIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListGetCodec.RequestParameters |
ListGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListLastIndexOfCodec.RequestParameters |
ListLastIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddCodec.RequestParameters |
ListAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveCodec.RequestParameters |
ListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListListIteratorCodec.RequestParameters |
ListListIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListCompareAndRetainAllCodec.RequestParameters |
ListCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveListenerCodec.RequestParameters |
ListRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListIsEmptyCodec.RequestParameters |
ListIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListCompareAndRemoveAllCodec.RequestParameters |
ListCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSizeCodec.RequestParameters |
ListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListContainsCodec.RequestParameters |
ListContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddWithIndexCodec.RequestParameters |
ListAddWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSubCodec.RequestParameters |
ListSubMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddListenerCodec.RequestParameters |
ListAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListGetAllCodec.RequestParameters |
ListGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveWithIndexCodec.RequestParameters |
ListRemoveWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddAllCodec.RequestParameters |
ListAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListContainsAllCodec.RequestParameters |
ListContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddAllWithIndexCodec.RequestParameters |
ListAddAllWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSetCodec.RequestParameters |
ListSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListClearCodec.RequestParameters |
ListClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
LockIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockGetRemainingLeaseTimeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockIsLockedByCurrentThreadMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockGetLockCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.LockIsLockedCodec.RequestParameters |
LockIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockGetRemainingLeaseTimeCodec.RequestParameters |
LockGetRemainingLeaseTimeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockForceUnlockCodec.RequestParameters |
LockForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockIsLockedByCurrentThreadCodec.RequestParameters |
LockIsLockedByCurrentThreadMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockLockCodec.RequestParameters |
LockLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockUnlockCodec.RequestParameters |
LockUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockTryLockCodec.RequestParameters |
LockTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockGetLockCountCodec.RequestParameters |
LockGetLockCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
LockForceUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetLockCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetRemainingLeaseTimeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedByCurrentThreadMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockTryLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractMapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MapAddNearCacheInvalidationListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
Pre38MapAddNearCacheEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapPutAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchNearCacheInvalidationMetadataTask.encodeResponse(Object response) |
protected ClientMessage |
MapPublisherCreateWithValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFlushMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapClearNearCacheMessageTask.encodeResponse(Object response)
Deprecated.
|
protected ClientMessage |
MapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapDestroyCacheMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchWithQueryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutTransientWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPublisherCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutTransientMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEventJournalReadTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetEntryViewMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddNearCacheInvalidationListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
Pre38MapAddNearCacheEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAggregateWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetTtlMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadGivenKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEventJournalSubscribeTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSubmitToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetReadCursorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchEntriesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutIfAbsentWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapMadePublishableMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapProjectionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapProjectionWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAssignAndGetUuidsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAggregateMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MapPutAllCodec.RequestParameters |
MapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerToKeyWithPredicateCodec.RequestParameters |
MapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntriesWithPagingPredicateCodec.RequestParameters |
MapEntriesWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetCodec.RequestParameters |
MapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapFetchNearCacheInvalidationMetadataCodec.RequestParameters |
MapFetchNearCacheInvalidationMetadataTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryPublisherCreateWithValueCodec.RequestParameters |
MapPublisherCreateWithValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddIndexCodec.RequestParameters |
MapAddIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapFlushCodec.RequestParameters |
MapFlushMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnKeysCodec.RequestParameters |
MapExecuteOnKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReplaceCodec.RequestParameters |
MapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveAllCodec.RequestParameters |
MapRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapClearNearCacheCodec.RequestParameters |
MapClearNearCacheMessageTask.decodeClientMessage(ClientMessage clientMessage)
Deprecated.
|
protected com.hazelcast.client.impl.protocol.codec.MapKeySetCodec.RequestParameters |
MapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryDestroyCacheCodec.RequestParameters |
MapDestroyCacheMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapFetchWithQueryCodec.RequestParameters |
MapFetchWithQueryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetAllCodec.RequestParameters |
MapGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntriesWithPredicateCodec.RequestParameters |
MapEntriesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryLockCodec.RequestParameters |
MapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddPartitionLostListenerCodec.RequestParameters |
MapAddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapIsLockedCodec.RequestParameters |
MapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLoadAllCodec.RequestParameters |
MapLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapDeleteCodec.RequestParameters |
MapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSizeCodec.RequestParameters |
MapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutTransientWithMaxIdleCodec.RequestParameters |
MapPutTransientWithMaxIdleMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddInterceptorCodec.RequestParameters |
MapAddInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveInterceptorCodec.RequestParameters |
MapRemoveInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryPublisherCreateCodec.RequestParameters |
MapPublisherCreateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLockCodec.RequestParameters |
MapLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapUnlockCodec.RequestParameters |
MapUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutTransientCodec.RequestParameters |
MapPutTransientMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapForceUnlockCodec.RequestParameters |
MapForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEventJournalReadCodec.RequestParameters |
MapEventJournalReadTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetEntryViewCodec.RequestParameters |
MapGetEntryViewMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters |
MapAddNearCacheInvalidationListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSetCodec.RequestParameters |
MapSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapFetchKeysCodec.RequestParameters |
MapFetchKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnAllKeysCodec.RequestParameters |
MapExecuteOnAllKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesCodec.RequestParameters |
MapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemovePartitionLostListenerCodec.RequestParameters |
MapRemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapClearCodec.RequestParameters |
MapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddNearCacheEntryListenerCodec.RequestParameters |
Pre38MapAddNearCacheEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAggregateWithPredicateCodec.RequestParameters |
MapAggregateWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSetTtlCodec.RequestParameters |
MapSetTtlMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLoadGivenKeysCodec.RequestParameters |
MapLoadGivenKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSetWithMaxIdleCodec.RequestParameters |
MapSetWithMaxIdleMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetWithPagingPredicateCodec.RequestParameters |
MapKeySetWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapContainsKeyCodec.RequestParameters |
MapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutIfAbsentCodec.RequestParameters |
MapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEventJournalSubscribeCodec.RequestParameters |
MapEventJournalSubscribeTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutWithMaxIdleCodec.RequestParameters |
MapPutWithMaxIdleMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetWithPredicateCodec.RequestParameters |
MapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutCodec.RequestParameters |
MapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteWithPredicateCodec.RequestParameters |
MapExecuteWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntrySetCodec.RequestParameters |
MapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapContainsValueCodec.RequestParameters |
MapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSubmitToKeyCodec.RequestParameters |
MapSubmitToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnKeyCodec.RequestParameters |
MapExecuteOnKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ContinuousQuerySetReadCursorCodec.RequestParameters |
MapSetReadCursorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapFetchEntriesCodec.RequestParameters |
MapFetchEntriesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesWithPagingPredicateCodec.RequestParameters |
MapValuesWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutIfAbsentWithMaxIdleCodec.RequestParameters |
MapPutIfAbsentWithMaxIdleMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReplaceIfSameCodec.RequestParameters |
MapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryMadePublishableCodec.RequestParameters |
MapMadePublishableMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerToKeyCodec.RequestParameters |
MapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryPutCodec.RequestParameters |
MapTryPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ContinuousQueryAddListenerCodec.RequestParameters |
MapAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryRemoveCodec.RequestParameters |
MapTryRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerCodec.RequestParameters |
MapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEvictAllCodec.RequestParameters |
MapEvictAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveEntryListenerCodec.RequestParameters |
MapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapProjectCodec.RequestParameters |
MapProjectionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveIfSameCodec.RequestParameters |
MapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapProjectWithPredicateCodec.RequestParameters |
MapProjectionWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerWithPredicateCodec.RequestParameters |
MapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveCodec.RequestParameters |
MapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEvictCodec.RequestParameters |
MapEvictMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapIsEmptyCodec.RequestParameters |
MapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesWithPredicateCodec.RequestParameters |
MapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAssignAndGetUuidsCodec.RequestParameters |
MapAssignAndGetUuidsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAggregateCodec.RequestParameters |
MapAggregateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapReduceCancelMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForMapMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceJobProcessInformationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForCustomMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForListMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForMultiMapMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MapReduceCancelCodec.RequestParameters |
MapReduceCancelMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForMapCodec.RequestParameters |
MapReduceForMapMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceJobProcessInformationCodec.RequestParameters |
MapReduceJobProcessInformationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForSetCodec.RequestParameters |
MapReduceForSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForCustomCodec.RequestParameters |
MapReduceForCustomMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForListCodec.RequestParameters |
MapReduceForListMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForMultiMapCodec.RequestParameters |
MapReduceForMultiMapMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AbstractMapReduceTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceCancelMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForCustomMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForListMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMultiMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceJobProcessInformationMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected abstract ClientMessage |
AbstractMultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValueCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapKeySetMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MultiMapAddEntryListenerToKeyCodec.RequestParameters |
MultiMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapDeleteCodec.RequestParameters |
MultiMapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsValueCodec.RequestParameters |
MultiMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapValuesCodec.RequestParameters |
MultiMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapForceUnlockCodec.RequestParameters |
MultiMapForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveCodec.RequestParameters |
MultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapValueCountCodec.RequestParameters |
MultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapEntrySetCodec.RequestParameters |
MultiMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapUnlockCodec.RequestParameters |
MultiMapUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsKeyCodec.RequestParameters |
MultiMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapGetCodec.RequestParameters |
MultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapClearCodec.RequestParameters |
MultiMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapIsLockedCodec.RequestParameters |
MultiMapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsEntryCodec.RequestParameters |
MultiMapContainsEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapAddEntryListenerCodec.RequestParameters |
MultiMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapTryLockCodec.RequestParameters |
MultiMapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapLockCodec.RequestParameters |
MultiMapLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapSizeCodec.RequestParameters |
MultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveEntryListenerCodec.RequestParameters |
MultiMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapPutCodec.RequestParameters |
MultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveEntryCodec.RequestParameters |
MultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapKeySetCodec.RequestParameters |
MultiMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
QueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueOfferMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMaxSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemainingCapacityMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.QueuePeekCodec.RequestParameters |
QueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueSizeCodec.RequestParameters |
QueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemoveListenerCodec.RequestParameters |
QueueRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueOfferCodec.RequestParameters |
QueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueDrainToMaxSizeCodec.RequestParameters |
QueueDrainMaxSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueIteratorCodec.RequestParameters |
QueueIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemainingCapacityCodec.RequestParameters |
QueueRemainingCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueAddListenerCodec.RequestParameters |
QueueAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueIsEmptyCodec.RequestParameters |
QueueIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueContainsCodec.RequestParameters |
QueueContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueuePutCodec.RequestParameters |
QueuePutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemoveCodec.RequestParameters |
QueueRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueCompareAndRemoveAllCodec.RequestParameters |
QueueCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueAddAllCodec.RequestParameters |
QueueAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueCompareAndRetainAllCodec.RequestParameters |
QueueCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueContainsAllCodec.RequestParameters |
QueueContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueTakeCodec.RequestParameters |
QueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueClearCodec.RequestParameters |
QueueClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueuePollCodec.RequestParameters |
QueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueDrainToCodec.RequestParameters |
QueueDrainMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ReplicatedMapAddNearCacheListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddNearCacheListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapPutAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddNearCacheEntryListenerCodec.RequestParameters |
ReplicatedMapAddNearCacheListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapPutCodec.RequestParameters |
ReplicatedMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapSizeCodec.RequestParameters |
ReplicatedMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapRemoveEntryListenerCodec.RequestParameters |
ReplicatedMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapValuesCodec.RequestParameters |
ReplicatedMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapGetCodec.RequestParameters |
ReplicatedMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerCodec.RequestParameters |
ReplicatedMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapEntrySetCodec.RequestParameters |
ReplicatedMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapIsEmptyCodec.RequestParameters |
ReplicatedMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapKeySetCodec.RequestParameters |
ReplicatedMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapRemoveCodec.RequestParameters |
ReplicatedMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapClearCodec.RequestParameters |
ReplicatedMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerToKeyCodec.RequestParameters |
ReplicatedMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapContainsValueCodec.RequestParameters |
ReplicatedMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.RequestParameters |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapContainsKeyCodec.RequestParameters |
ReplicatedMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerWithPredicateCodec.RequestParameters |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapPutAllCodec.RequestParameters |
ReplicatedMapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
RingbufferTailSequenceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferReadOneMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferHeadSequenceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferRemainingCapacityMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferReadManyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferCapacityMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.RingbufferTailSequenceCodec.RequestParameters |
RingbufferTailSequenceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferReadOneCodec.RequestParameters |
RingbufferReadOneMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferHeadSequenceCodec.RequestParameters |
RingbufferHeadSequenceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferRemainingCapacityCodec.RequestParameters |
RingbufferRemainingCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferAddCodec.RequestParameters |
RingbufferAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferAddAllCodec.RequestParameters |
RingbufferAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferReadManyCodec.RequestParameters |
RingbufferReadManyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferSizeCodec.RequestParameters |
RingbufferSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferCapacityCodec.RequestParameters |
RingbufferCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
RingbufferAddAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferHeadSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadManyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadOneMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferRemainingCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferTailSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ScheduledExecutorTaskIsDoneFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskDisposeFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorSubmitToAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorGetAllScheduledMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskIsDoneFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetDelayFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetResultFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetDelayFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskCancelFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetResultFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetStatisticsFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskIsCancelledFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetStatisticsFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskCancelFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskDisposeFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskIsCancelledFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorSubmitToPartitionMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsDoneFromPartitionCodec.RequestParameters |
ScheduledExecutorTaskIsDoneFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorDisposeFromAddressCodec.RequestParameters |
ScheduledExecutorTaskDisposeFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorSubmitToAddressCodec.RequestParameters |
ScheduledExecutorSubmitToAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetAllScheduledFuturesCodec.RequestParameters |
ScheduledExecutorGetAllScheduledMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsDoneFromAddressCodec.RequestParameters |
ScheduledExecutorTaskIsDoneFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetDelayFromAddressCodec.RequestParameters |
ScheduledExecutorTaskGetDelayFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetResultFromPartitionCodec.RequestParameters |
ScheduledExecutorTaskGetResultFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetDelayFromPartitionCodec.RequestParameters |
ScheduledExecutorTaskGetDelayFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorCancelFromPartitionCodec.RequestParameters |
ScheduledExecutorTaskCancelFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetResultFromAddressCodec.RequestParameters |
ScheduledExecutorTaskGetResultFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorShutdownCodec.RequestParameters |
ScheduledExecutorShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetStatsFromAddressCodec.RequestParameters |
ScheduledExecutorTaskGetStatisticsFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsCancelledFromPartitionCodec.RequestParameters |
ScheduledExecutorTaskIsCancelledFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorGetStatsFromPartitionCodec.RequestParameters |
ScheduledExecutorTaskGetStatisticsFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorCancelFromAddressCodec.RequestParameters |
ScheduledExecutorTaskCancelFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorDisposeFromPartitionCodec.RequestParameters |
ScheduledExecutorTaskDisposeFromPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorIsCancelledFromAddressCodec.RequestParameters |
ScheduledExecutorTaskIsCancelledFromAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ScheduledExecutorSubmitToPartitionCodec.RequestParameters |
ScheduledExecutorSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
SemaphoreReleaseMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreIncreasePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreAcquireMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreReducePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreAvailablePermitsMessageTasks.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreInitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreDrainPermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreTryAcquireMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.SemaphoreReleaseCodec.RequestParameters |
SemaphoreReleaseMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreIncreasePermitsCodec.RequestParameters |
SemaphoreIncreasePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreAcquireCodec.RequestParameters |
SemaphoreAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreReducePermitsCodec.RequestParameters |
SemaphoreReducePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreAvailablePermitsCodec.RequestParameters |
SemaphoreAvailablePermitsMessageTasks.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreInitCodec.RequestParameters |
SemaphoreInitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreDrainPermitsCodec.RequestParameters |
SemaphoreDrainPermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreTryAcquireCodec.RequestParameters |
SemaphoreTryAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
SemaphoreAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreAvailablePermitsMessageTasks(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreDrainPermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreIncreasePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreInitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReducePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReleaseMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreTryAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
SetContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRetainAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.SetContainsCodec.RequestParameters |
SetContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddAllCodec.RequestParameters |
SetAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetGetAllCodec.RequestParameters |
SetGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetRemoveCodec.RequestParameters |
SetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetClearCodec.RequestParameters |
SetClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRemoveAllCodec.RequestParameters |
SetCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetRemoveListenerCodec.RequestParameters |
SetRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetSizeCodec.RequestParameters |
SetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddListenerCodec.RequestParameters |
SetAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetContainsAllCodec.RequestParameters |
SetContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddCodec.RequestParameters |
SetAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetIsEmptyCodec.RequestParameters |
SetIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRetainAllCodec.RequestParameters |
SetCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TopicRemoveMessageListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicPublishMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicAddMessageListenerMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TopicRemoveMessageListenerCodec.RequestParameters |
TopicRemoveMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TopicPublishCodec.RequestParameters |
TopicPublishMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec.RequestParameters |
TopicAddMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicPublishMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
XATransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAClearRemoteTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCommitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAFinalizeTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionPrepareMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XACollectTransactionsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionCommitMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.XATransactionCreateCodec.RequestParameters |
XATransactionCreateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionRollbackCodec.RequestParameters |
XATransactionRollbackMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionClearRemoteCodec.RequestParameters |
XAClearRemoteTransactionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionCommitCodec.RequestParameters |
TransactionCommitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionFinalizeCodec.RequestParameters |
XAFinalizeTransactionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionPrepareCodec.RequestParameters |
XATransactionPrepareMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionCollectTransactionsCodec.RequestParameters |
XACollectTransactionsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionRollbackCodec.RequestParameters |
TransactionRollbackMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionCreateCodec.RequestParameters |
TransactionCreateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionCommitCodec.RequestParameters |
XATransactionCommitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalListAddCodec.RequestParameters |
TransactionalListAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalListRemoveCodec.RequestParameters |
TransactionalListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalListSizeCodec.RequestParameters |
TransactionalListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalListAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMapValuesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetForUpdateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapIsEmptyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesWithPredicateCodec.RequestParameters |
TransactionalMapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceIfSameCodec.RequestParameters |
TransactionalMapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesCodec.RequestParameters |
TransactionalMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetCodec.RequestParameters |
TransactionalMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetWithPredicateCodec.RequestParameters |
TransactionalMapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapContainsKeyCodec.RequestParameters |
TransactionalMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapDeleteCodec.RequestParameters |
TransactionalMapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSizeCodec.RequestParameters |
TransactionalMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutIfAbsentCodec.RequestParameters |
TransactionalMapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSetCodec.RequestParameters |
TransactionalMapSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveIfSameCodec.RequestParameters |
TransactionalMapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutCodec.RequestParameters |
TransactionalMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetCodec.RequestParameters |
TransactionalMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetForUpdateCodec.RequestParameters |
TransactionalMapGetForUpdateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceCodec.RequestParameters |
TransactionalMapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveCodec.RequestParameters |
TransactionalMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapIsEmptyCodec.RequestParameters |
TransactionalMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapValueCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapPutCodec.RequestParameters |
TransactionalMultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapSizeCodec.RequestParameters |
TransactionalMultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapGetCodec.RequestParameters |
TransactionalMultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveEntryCodec.RequestParameters |
TransactionalMultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveCodec.RequestParameters |
TransactionalMultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapValueCountCodec.RequestParameters |
TransactionalMultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalMultiMapGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapPutMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveEntryMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapValueCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalQueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueOfferMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePollCodec.RequestParameters |
TransactionalQueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueTakeCodec.RequestParameters |
TransactionalQueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueSizeCodec.RequestParameters |
TransactionalQueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePeekCodec.RequestParameters |
TransactionalQueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueOfferCodec.RequestParameters |
TransactionalQueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalQueueOfferMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePeekMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePollMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueTakeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalSetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetRemoveCodec.RequestParameters |
TransactionalSetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetAddCodec.RequestParameters |
TransactionalSetAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetSizeCodec.RequestParameters |
TransactionalSetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalSetAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
static List<ClientMessage> |
ClientMessageSplitter.getSubFrames(int maxFrameSize,
ClientMessage clientMessage)
Splits a
ClientMessage into frames of a maximum size. |
Modifier and Type | Method and Description |
---|---|
static List<ClientMessage> |
ClientMessageSplitter.getSubFrames(int maxFrameSize,
ClientMessage clientMessage)
Splits a
ClientMessage into frames of a maximum size. |
Constructor and Description |
---|
ClientMessageDecoder(Connection connection,
Consumer<ClientMessage> dst) |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
ClientRingbufferProxy.invoke(ClientMessage clientMessage,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ClientTransactionUtil.invoke(ClientMessage request,
String objectName,
HazelcastClientInstanceImpl client,
Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions.
|
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ClientTransactionUtil.invoke(ClientMessage request,
String objectName,
HazelcastClientInstanceImpl client,
Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions.
|
Modifier and Type | Method and Description |
---|---|
Consumer<ClientMessage> |
ClientInvocationService.getResponseHandler() |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
ClientProxy.invoke(ClientMessage clientMessage) |
protected <T> T |
ClientProxy.invoke(ClientMessage clientMessage,
Object key) |
protected <T> T |
ClientProxy.invokeOnAddress(ClientMessage clientMessage,
Address address) |
protected <T> T |
ClientProxy.invokeOnPartition(ClientMessage clientMessage,
int partitionId) |
protected <T> T |
ClientProxy.invokeOnPartitionInterruptibly(ClientMessage clientMessage,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ListenerMessageCodec.encodeAddRequest(boolean localOnly) |
ClientMessage |
ListenerMessageCodec.encodeRemoveRequest(String realRegistrationId) |
ClientMessage |
ClientInvocation.getClientMessage() |
ClientMessage |
ClientInvocationFuture.resolveAndThrowIfException(Object response) |
Modifier and Type | Method and Description |
---|---|
Consumer<ClientMessage> |
ClientResponseHandlerSupplier.get() |
Consumer<ClientMessage> |
AbstractClientInvocationService.getResponseHandler() |
Modifier and Type | Method and Description |
---|---|
String |
ListenerMessageCodec.decodeAddResponse(ClientMessage clientMessage) |
boolean |
ListenerMessageCodec.decodeRemoveResponse(ClientMessage clientMessage) |
void |
ClientInvocation.notify(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
void |
ClientInvocationFuture.andThen(ExecutionCallback<ClientMessage> callback) |
void |
ClientInvocationFuture.andThen(ExecutionCallback<ClientMessage> callback,
Executor executor) |
Constructor and Description |
---|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
String objectName)
Create an invocation that will be executed on random member.
|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
String objectName,
Address address)
Create an invocation that will be executed on member with given
address . |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
String objectName,
Connection connection)
Create an invocation that will be executed on given
connection . |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
String objectName,
int partitionId)
Create an invocation that will be executed on owner of
partitionId . |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
String objectName,
int partitionId,
Address address,
Connection connection) |
ClientInvocationFuture(ClientInvocation invocation,
Executor internalExecutor,
ClientMessage request,
ILogger logger,
CallIdSequence callIdSequence) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClientListenerService.handleClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AbstractCPMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
GetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetAndAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ApplyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CPAtomicLongGetCodec.RequestParameters |
GetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicLongGetAndAddCodec.RequestParameters |
GetAndAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicLongAlterCodec.RequestParameters |
AlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicLongGetAndSetCodec.RequestParameters |
GetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicLongCompareAndSetCodec.RequestParameters |
CompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicLongAddAndGetCodec.RequestParameters |
AddAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicLongApplyCodec.RequestParameters |
ApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AddAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
AlterMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ApplyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CompareAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetAndAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
GetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ContainsMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CPAtomicRefGetCodec.RequestParameters |
GetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicRefCompareAndSetCodec.RequestParameters |
CompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicRefApplyCodec.RequestParameters |
ApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicRefSetCodec.RequestParameters |
SetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPAtomicRefContainsCodec.RequestParameters |
ContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
ApplyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CompareAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ContainsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TrySetCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetRoundMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CPCountDownLatchTrySetCountCodec.RequestParameters |
TrySetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPCountDownLatchAwaitCodec.RequestParameters |
AwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPCountDownLatchCountDownCodec.RequestParameters |
CountDownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPCountDownLatchGetRoundCodec.RequestParameters |
GetRoundMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPCountDownLatchGetRoundCodec.RequestParameters |
GetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetRoundMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TrySetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
UnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetLockOwnershipStateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CPFencedLockUnlockCodec.RequestParameters |
UnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPFencedLockGetLockOwnershipCodec.RequestParameters |
GetLockOwnershipStateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPFencedLockTryLockCodec.RequestParameters |
TryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPFencedLockLockCodec.RequestParameters |
LockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
GetLockOwnershipStateMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TryLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
UnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ChangePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetSemaphoreTypeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AvailablePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AcquirePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DrainPermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
InitSemaphoreMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReleasePermitsMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CPSemaphoreChangeCodec.RequestParameters |
ChangePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSemaphoreGetSemaphoreTypeCodec.RequestParameters |
GetSemaphoreTypeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSemaphoreAvailablePermitsCodec.RequestParameters |
AvailablePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSemaphoreAcquireCodec.RequestParameters |
AcquirePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSemaphoreDrainCodec.RequestParameters |
DrainPermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSemaphoreInitCodec.RequestParameters |
InitSemaphoreMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSemaphoreReleaseCodec.RequestParameters |
ReleasePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AcquirePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
AvailablePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ChangePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DrainPermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetSemaphoreTypeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
InitSemaphoreMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ReleasePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
DestroyRaftObjectMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateRaftGroupMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CPGroupDestroyCPObjectCodec.RequestParameters |
DestroyRaftObjectMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPGroupCreateCPGroupCodec.RequestParameters |
CreateRaftGroupMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CreateRaftGroupMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DestroyRaftObjectMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
HeartbeatSessionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GenerateThreadIdMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CloseSessionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateSessionMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CPSessionHeartbeatSessionCodec.RequestParameters |
HeartbeatSessionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSessionGenerateThreadIdCodec.RequestParameters |
GenerateThreadIdMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSessionCloseSessionCodec.RequestParameters |
CloseSessionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CPSessionCreateSessionCodec.RequestParameters |
CreateSessionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CloseSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CreateSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GenerateThreadIdMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
HeartbeatSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
NewIdBatchMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.FlakeIdGeneratorNewIdBatchCodec.RequestParameters |
NewIdBatchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
NewIdBatchMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected abstract ClientMessage |
AbstractBaseNearCacheInvalidationListener.encodeBatchInvalidation(String name,
List<Data> keys,
List<String> sourceUuids,
List<UUID> partitionUuids,
List<Long> sequences) |
protected abstract ClientMessage |
AbstractBaseNearCacheInvalidationListener.encodeSingleInvalidation(String name,
Data key,
String sourceUuid,
UUID partitionUuid,
long sequence) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractBaseNearCacheInvalidationListener.sendMessageWithOrderKey(ClientMessage clientMessage,
Object orderKey) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.