Package | Description |
---|---|
com.hazelcast.client.connection |
Provides connection interfaces/classes for com.hazelcast.client
|
com.hazelcast.client.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
com.hazelcast.client.impl |
Contains most of the client side HazelcastInstance implementation functionality.
|
com.hazelcast.client.impl.protocol |
Client protocol related private implementation classes
|
com.hazelcast.client.impl.protocol.codec |
Client protocol custom codec implementations
|
com.hazelcast.client.impl.protocol.parameters | |
com.hazelcast.client.impl.protocol.task |
Client tasks associated with requests.
|
com.hazelcast.client.impl.protocol.task.atomiclong |
Client protocol tasks implementations for AtomicLong
|
com.hazelcast.client.impl.protocol.task.atomicreference |
Client protocol tasks implementations for AtomicReference
|
com.hazelcast.client.impl.protocol.task.cache |
Client protocol tasks implementations for JCache
|
com.hazelcast.client.impl.protocol.task.condition |
Client protocol tasks implementations for Condition
|
com.hazelcast.client.impl.protocol.task.countdownlatch |
Client protocol tasks implementations for CountDownLatch
|
com.hazelcast.client.impl.protocol.task.executorservice |
Client protocol tasks implementations for ExecutorService
|
com.hazelcast.client.impl.protocol.task.list |
Client protocol tasks implementations for List
|
com.hazelcast.client.impl.protocol.task.lock |
Client protocol tasks implementations for ILock
|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.client.impl.protocol.task.mapreduce |
Client protocol tasks implementations for map reduce
|
com.hazelcast.client.impl.protocol.task.multimap |
Client protocol tasks implementations for multi map
|
com.hazelcast.client.impl.protocol.task.queue |
Client protocol tasks implementations for Queue
|
com.hazelcast.client.impl.protocol.task.replicatedmap |
Client protocol tasks implementations for ReplicatedMap
|
com.hazelcast.client.impl.protocol.task.ringbuffer |
Client protocol tasks implementations for Ringbuffer
|
com.hazelcast.client.impl.protocol.task.semaphore |
Client protocol tasks implementations for Semaphore
|
com.hazelcast.client.impl.protocol.task.set |
Client protocol tasks implementations for set
|
com.hazelcast.client.impl.protocol.task.topic |
Client protocol tasks implementations for Topic
|
com.hazelcast.client.impl.protocol.task.transaction |
Client protocol tasks implementations for Transaction related
|
com.hazelcast.client.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.spi |
Contains classes/interfaces related to Service Provider Interface
such as ClientProxy , ClientClusterService
|
com.hazelcast.client.spi.impl |
Provides util classes for com.hazelcast.client
|
com.hazelcast.client.spi.impl.listener | |
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.nio.tcp |
Contains functionality for the TCP/IP Networking between cluster members
|
Modifier and Type | Method and Description |
---|---|
void |
ClientConnectionManager.handleClientMessage(ClientMessage message,
Connection connection)
Handles incoming network package
|
Modifier and Type | Method and Description |
---|---|
void |
ClientConnectionManagerImpl.handleClientMessage(ClientMessage message,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
<T> T |
ClientMessageDecoder.decodeClientMessage(ClientMessage clientMessage) |
void |
ClientEngineImpl.handleClientMessage(ClientMessage clientMessage,
Connection connection) |
void |
ClientEndpointImpl.sendClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ClientMessage.addFlag(short flags)
Sets the flags field value.
|
static ClientMessage |
ClientMessage.create() |
ClientMessage |
ClientExceptionFactory.createExceptionMessage(Throwable throwable) |
static ClientMessage |
ClientMessage.createForDecode(ClientProtocolBuffer buffer,
int offset) |
static ClientMessage |
ClientMessage.createForEncode(ClientProtocolBuffer buffer,
int offset) |
static ClientMessage |
ClientMessage.createForEncode(int initialCapacity) |
ClientMessage |
ClientMessage.setCorrelationId(long correlationId)
Sets the correlation id field.
|
ClientMessage |
ClientMessage.setDataOffset(int dataOffset)
Sets the dataOffset field.
|
ClientMessage |
ClientMessage.setFrameLength(int length)
Sets the frame length field.
|
ClientMessage |
ClientMessage.setMessageType(int type)
Sets the message type field.
|
ClientMessage |
ClientMessage.setPartitionId(int partitionId)
Sets the partition id field.
|
ClientMessage |
ClientMessage.setVersion(short version)
Sets the version field value.
|
ClientMessage |
ClientMessage.updateFrameLength() |
Modifier and Type | Method and Description |
---|---|
MessageTask |
MessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
Throwable |
ClientExceptionFactory.createException(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
static Member |
MemberCodec.decode(ClientMessage clientMessage) |
static Address |
AddressCodec.decode(ClientMessage clientMessage) |
static DistributedObjectInfo |
DistributedObjectInfoCodec.decode(ClientMessage clientMessage) |
static StackTraceElement |
StackTraceElementCodec.decode(ClientMessage clientMessage) |
static CacheEventData |
CacheEventDataCodec.decode(ClientMessage clientMessage) |
static QueryCacheEventData |
QueryCacheEventDataCodec.decode(ClientMessage clientMessage) |
static JobPartitionState |
JobPartitionStateCodec.decode(ClientMessage clientMessage) |
static SimpleEntryView<Data,Data> |
EntryViewCodec.decode(ClientMessage clientMessage) |
static Xid |
XIDCodec.decode(ClientMessage clientMessage) |
static void |
AddressCodec.encode(Address address,
ClientMessage clientMessage) |
static void |
CacheEventDataCodec.encode(CacheEventData cacheEventData,
ClientMessage clientMessage) |
static void |
DistributedObjectInfoCodec.encode(DistributedObjectInfo info,
ClientMessage clientMessage) |
static void |
JobPartitionStateCodec.encode(JobPartitionState jobPartitionState,
ClientMessage clientMessage) |
static void |
MemberCodec.encode(Member member,
ClientMessage clientMessage) |
static void |
QueryCacheEventDataCodec.encode(QueryCacheEventData queryCacheEventData,
ClientMessage clientMessage) |
static void |
EntryViewCodec.encode(SimpleEntryView<Data,Data> dataEntryView,
ClientMessage clientMessage) |
static void |
StackTraceElementCodec.encode(StackTraceElement stackTraceElement,
ClientMessage clientMessage) |
static void |
XIDCodec.encode(Xid xid,
ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ErrorCodec.encode(int errorCode,
String className,
String message,
StackTraceElement[] stackTrace,
int causeErrorCode,
String causeClassName) |
Modifier and Type | Method and Description |
---|---|
static ErrorCodec |
ErrorCodec.decode(ClientMessage flyweight) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
AbstractMessageTask.clientMessage |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
AuthenticationMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte version) |
protected abstract ClientMessage |
AuthenticationBaseMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte serializationVersion) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte version) |
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 |
AuthenticationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveAllListenersMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DestroyProxyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetDistributedObjectsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveDistributedObjectListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeResponse(Object response) |
protected abstract ClientMessage |
AbstractMessageTask.encodeResponse(Object response) |
protected ClientMessage |
NoSuchMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateProxyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ClientPingCodec.RequestParameters |
PingMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters |
AddDistributedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemovePartitionLostListenerCodec.RequestParameters |
RemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddMembershipListenerCodec.RequestParameters |
AddMembershipListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientGetPartitionsCodec.RequestParameters |
GetPartitionsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAuthenticationCodec.RequestParameters |
AuthenticationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveAllListenersCodec.RequestParameters |
RemoveAllListenersMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientDestroyProxyCodec.RequestParameters |
DestroyProxyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientGetDistributedObjectsCodec.RequestParameters |
GetDistributedObjectsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientRemoveDistributedObjectListenerCodec.RequestParameters |
RemoveDistributedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAddPartitionLostListenerCodec.RequestParameters |
AddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientAuthenticationCustomCodec.RequestParameters |
AuthenticationCustomCredentialsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected abstract P |
AbstractMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ClientCreateProxyCodec.RequestParameters |
CreateProxyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected void |
AbstractMessageTask.sendClientMessage(ClientMessage resultClientMessage) |
protected void |
AbstractMessageTask.sendClientMessage(Object key,
ClientMessage resultClientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AtomicLongGetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAlterAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongDecrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongAddAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongCompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndIncrementMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongGetAndAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongIncrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicLongSetMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndSetCodec.RequestParameters |
AtomicLongGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAlterAndGetCodec.RequestParameters |
AtomicLongAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndAddCodec.RequestParameters |
AtomicLongGetAndAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongDecrementAndGetCodec.RequestParameters |
AtomicLongDecrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongApplyCodec.RequestParameters |
AtomicLongApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAlterCodec.RequestParameters |
AtomicLongAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongAddAndGetCodec.RequestParameters |
AtomicLongAddAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongCompareAndSetCodec.RequestParameters |
AtomicLongCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndIncrementCodec.RequestParameters |
AtomicLongGetAndIncrementMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetCodec.RequestParameters |
AtomicLongGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongGetAndAlterCodec.RequestParameters |
AtomicLongGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongIncrementAndGetCodec.RequestParameters |
AtomicLongIncrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicLongSetCodec.RequestParameters |
AtomicLongSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AtomicReferenceCompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceAlterAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetAndAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceSetAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceIsNullMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceAlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AtomicReferenceClearMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceCompareAndSetCodec.RequestParameters |
AtomicReferenceCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceAlterAndGetCodec.RequestParameters |
AtomicReferenceAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceContainsCodec.RequestParameters |
AtomicReferenceContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetAndAlterCodec.RequestParameters |
AtomicReferenceGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceSetAndGetCodec.RequestParameters |
AtomicReferenceSetAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetAndSetCodec.RequestParameters |
AtomicReferenceGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceGetCodec.RequestParameters |
AtomicReferenceGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceIsNullCodec.RequestParameters |
AtomicReferenceIsNullMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceAlterCodec.RequestParameters |
AtomicReferenceAlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceSetCodec.RequestParameters |
AtomicReferenceSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceApplyCodec.RequestParameters |
AtomicReferenceApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.AtomicReferenceClearCodec.RequestParameters |
AtomicReferenceClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CacheDestroyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheIterateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheListenerRegistrationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEntryProcessorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddInvalidationListenerTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheCreateConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveInvalidationListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheManagementConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemovePartitionLostListenerMessageTask.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.CacheIterateCodec.RequestParameters |
CacheIterateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheLoadAllCodec.RequestParameters |
CacheLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetCodec.RequestParameters |
CacheGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheListenerRegistrationCodec.RequestParameters |
CacheListenerRegistrationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheEntryProcessorCodec.RequestParameters |
CacheEntryProcessorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddEntryListenerCodec.RequestParameters |
CacheAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CachePutIfAbsentCodec.RequestParameters |
CachePutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveEntryListenerCodec.RequestParameters |
CacheRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheSizeCodec.RequestParameters |
CacheSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAndReplaceCodec.RequestParameters |
CacheGetAndReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CachePutCodec.RequestParameters |
CachePutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheAddInvalidationListenerCodec.RequestParameters |
CacheAddInvalidationListenerTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.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.CacheContainsKeyCodec.RequestParameters |
CacheContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheCreateConfigCodec.RequestParameters |
CacheCreateConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetConfigCodec.RequestParameters |
CacheGetConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveInvalidationListenerCodec.RequestParameters |
CacheRemoveInvalidationListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveAllKeysCodec.RequestParameters |
CacheRemoveAllKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheGetAndRemoveCodec.RequestParameters |
CacheGetAndRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemoveAllCodec.RequestParameters |
CacheRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheClearCodec.RequestParameters |
CacheClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheManagementConfigCodec.RequestParameters |
CacheManagementConfigMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CacheRemovePartitionLostListenerCodec.RequestParameters |
CacheRemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ConditionSignalAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionBeforeAwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionSignalMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ConditionAwaitMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ConditionSignalAllCodec.RequestParameters |
ConditionSignalAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionBeforeAwaitCodec.RequestParameters |
ConditionBeforeAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionSignalCodec.RequestParameters |
ConditionSignalMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ConditionAwaitCodec.RequestParameters |
ConditionAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
ConditionAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionBeforeAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ConditionSignalMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CountDownLatchGetCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchAwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchCountDownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownLatchTrySetCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchGetCountCodec.RequestParameters |
CountDownLatchGetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchAwaitCodec.RequestParameters |
CountDownLatchAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchCountDownCodec.RequestParameters |
CountDownLatchCountDownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.CountDownLatchTrySetCountCodec.RequestParameters |
CountDownLatchTrySetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CountDownLatchAwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchCountDownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchGetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownLatchTrySetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ExecutorServiceIsShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToAddressMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceIsShutdownCodec.RequestParameters |
ExecutorServiceIsShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceShutdownCodec.RequestParameters |
ExecutorServiceShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceCancelOnPartitionCodec.RequestParameters |
ExecutorServiceCancelOnPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceSubmitToPartitionCodec.RequestParameters |
ExecutorServiceSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceCancelOnAddressCodec.RequestParameters |
ExecutorServiceCancelOnAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ExecutorServiceSubmitToAddressCodec.RequestParameters |
ExecutorServiceSubmitToAddressMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AbstractExecutorServiceCancelMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceCancelOnAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceCancelOnPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListLastIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSubMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListClearMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ListIteratorCodec.RequestParameters |
ListIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListIndexOfCodec.RequestParameters |
ListIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListGetCodec.RequestParameters |
ListGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListLastIndexOfCodec.RequestParameters |
ListLastIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddCodec.RequestParameters |
ListAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveCodec.RequestParameters |
ListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListListIteratorCodec.RequestParameters |
ListListIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListCompareAndRetainAllCodec.RequestParameters |
ListCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveListenerCodec.RequestParameters |
ListRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListIsEmptyCodec.RequestParameters |
ListIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListCompareAndRemoveAllCodec.RequestParameters |
ListCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSizeCodec.RequestParameters |
ListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListContainsCodec.RequestParameters |
ListContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddWithIndexCodec.RequestParameters |
ListAddWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSubCodec.RequestParameters |
ListSubMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddListenerCodec.RequestParameters |
ListAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListGetAllCodec.RequestParameters |
ListGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListRemoveWithIndexCodec.RequestParameters |
ListRemoveWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddAllCodec.RequestParameters |
ListAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListContainsAllCodec.RequestParameters |
ListContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListAddAllWithIndexCodec.RequestParameters |
ListAddAllWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListSetCodec.RequestParameters |
ListSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ListClearCodec.RequestParameters |
ListClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
LockIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockGetRemainingLeaseTimeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockIsLockedByCurrentThreadMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockGetLockCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.LockIsLockedCodec.RequestParameters |
LockIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockGetRemainingLeaseTimeCodec.RequestParameters |
LockGetRemainingLeaseTimeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockForceUnlockCodec.RequestParameters |
LockForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockIsLockedByCurrentThreadCodec.RequestParameters |
LockIsLockedByCurrentThreadMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockLockCodec.RequestParameters |
LockLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockUnlockCodec.RequestParameters |
LockUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockTryLockCodec.RequestParameters |
LockTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.LockGetLockCountCodec.RequestParameters |
LockGetLockCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
LockForceUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetLockCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockGetRemainingLeaseTimeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedByCurrentThreadMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockIsLockedMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockTryLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockUnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractMapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MapAddNearCacheEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapPutAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFlushMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapClearNearCacheMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutTransientMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetEntryViewMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadGivenKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddNearCacheEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSubmitToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPredicateMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MapPutAllCodec.RequestParameters |
MapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerToKeyWithPredicateCodec.RequestParameters |
MapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntriesWithPagingPredicateCodec.RequestParameters |
MapEntriesWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetCodec.RequestParameters |
MapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddIndexCodec.RequestParameters |
MapAddIndexMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapFlushCodec.RequestParameters |
MapFlushMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnKeysCodec.RequestParameters |
MapExecuteOnKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReplaceCodec.RequestParameters |
MapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapClearNearCacheCodec.RequestParameters |
MapClearNearCacheMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetCodec.RequestParameters |
MapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapGetAllCodec.RequestParameters |
MapGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntriesWithPredicateCodec.RequestParameters |
MapEntriesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryLockCodec.RequestParameters |
MapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddPartitionLostListenerCodec.RequestParameters |
MapAddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapIsLockedCodec.RequestParameters |
MapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLoadAllCodec.RequestParameters |
MapLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapDeleteCodec.RequestParameters |
MapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSizeCodec.RequestParameters |
MapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddInterceptorCodec.RequestParameters |
MapAddInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveInterceptorCodec.RequestParameters |
MapRemoveInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.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.MapGetEntryViewCodec.RequestParameters |
MapGetEntryViewMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSetCodec.RequestParameters |
MapSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnAllKeysCodec.RequestParameters |
MapExecuteOnAllKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesCodec.RequestParameters |
MapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemovePartitionLostListenerCodec.RequestParameters |
MapRemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapClearCodec.RequestParameters |
MapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapLoadGivenKeysCodec.RequestParameters |
MapLoadGivenKeysMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetWithPagingPredicateCodec.RequestParameters |
MapKeySetWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapContainsKeyCodec.RequestParameters |
MapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutIfAbsentCodec.RequestParameters |
MapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapKeySetWithPredicateCodec.RequestParameters |
MapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapPutCodec.RequestParameters |
MapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteWithPredicateCodec.RequestParameters |
MapExecuteWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEntrySetCodec.RequestParameters |
MapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapContainsValueCodec.RequestParameters |
MapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddNearCacheEntryListenerCodec.RequestParameters |
MapAddNearCacheEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapSubmitToKeyCodec.RequestParameters |
MapSubmitToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapExecuteOnKeyCodec.RequestParameters |
MapExecuteOnKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesWithPagingPredicateCodec.RequestParameters |
MapValuesWithPagingPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReplaceIfSameCodec.RequestParameters |
MapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerToKeyCodec.RequestParameters |
MapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryPutCodec.RequestParameters |
MapTryPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapTryRemoveCodec.RequestParameters |
MapTryRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerCodec.RequestParameters |
MapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEvictAllCodec.RequestParameters |
MapEvictAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveEntryListenerCodec.RequestParameters |
MapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveIfSameCodec.RequestParameters |
MapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapAddEntryListenerWithPredicateCodec.RequestParameters |
MapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapRemoveCodec.RequestParameters |
MapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapEvictCodec.RequestParameters |
MapEvictMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapIsEmptyCodec.RequestParameters |
MapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapValuesWithPredicateCodec.RequestParameters |
MapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapReduceCancelMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForMapMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceJobProcessInformationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForCustomMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForListMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReduceForMultiMapMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MapReduceCancelCodec.RequestParameters |
MapReduceCancelMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForMapCodec.RequestParameters |
MapReduceForMapMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceJobProcessInformationCodec.RequestParameters |
MapReduceJobProcessInformationMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForSetCodec.RequestParameters |
MapReduceForSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForCustomCodec.RequestParameters |
MapReduceForCustomMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForListCodec.RequestParameters |
MapReduceForListMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MapReduceForMultiMapCodec.RequestParameters |
MapReduceForMultiMapMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AbstractMapReduceTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceCancelMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForCustomMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForListMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForMultiMapMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceForSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
MapReduceJobProcessInformationMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected abstract ClientMessage |
AbstractMultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValueCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapKeySetMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MultiMapAddEntryListenerToKeyCodec.RequestParameters |
MultiMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsValueCodec.RequestParameters |
MultiMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapValuesCodec.RequestParameters |
MultiMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapForceUnlockCodec.RequestParameters |
MultiMapForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveCodec.RequestParameters |
MultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapValueCountCodec.RequestParameters |
MultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapEntrySetCodec.RequestParameters |
MultiMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapUnlockCodec.RequestParameters |
MultiMapUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsKeyCodec.RequestParameters |
MultiMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapGetCodec.RequestParameters |
MultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapClearCodec.RequestParameters |
MultiMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapIsLockedCodec.RequestParameters |
MultiMapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapContainsEntryCodec.RequestParameters |
MultiMapContainsEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapAddEntryListenerCodec.RequestParameters |
MultiMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapTryLockCodec.RequestParameters |
MultiMapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapLockCodec.RequestParameters |
MultiMapLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapSizeCodec.RequestParameters |
MultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveEntryListenerCodec.RequestParameters |
MultiMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapPutCodec.RequestParameters |
MultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapRemoveEntryCodec.RequestParameters |
MultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.MultiMapKeySetCodec.RequestParameters |
MultiMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
QueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueOfferMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMaxSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemainingCapacityMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.QueuePeekCodec.RequestParameters |
QueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueSizeCodec.RequestParameters |
QueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemoveListenerCodec.RequestParameters |
QueueRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueOfferCodec.RequestParameters |
QueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueDrainToMaxSizeCodec.RequestParameters |
QueueDrainMaxSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueIteratorCodec.RequestParameters |
QueueIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemainingCapacityCodec.RequestParameters |
QueueRemainingCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueAddListenerCodec.RequestParameters |
QueueAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueIsEmptyCodec.RequestParameters |
QueueIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueContainsCodec.RequestParameters |
QueueContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueuePutCodec.RequestParameters |
QueuePutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueRemoveCodec.RequestParameters |
QueueRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueCompareAndRemoveAllCodec.RequestParameters |
QueueCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueAddAllCodec.RequestParameters |
QueueAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueCompareAndRetainAllCodec.RequestParameters |
QueueCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueContainsAllCodec.RequestParameters |
QueueContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueTakeCodec.RequestParameters |
QueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueClearCodec.RequestParameters |
QueueClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueuePollCodec.RequestParameters |
QueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.QueueDrainToCodec.RequestParameters |
QueueDrainMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ReplicatedMapAddNearCacheListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddNearCacheListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapPutAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddNearCacheEntryListenerCodec.RequestParameters |
ReplicatedMapAddNearCacheListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapPutCodec.RequestParameters |
ReplicatedMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapSizeCodec.RequestParameters |
ReplicatedMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapRemoveEntryListenerCodec.RequestParameters |
ReplicatedMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapValuesCodec.RequestParameters |
ReplicatedMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapGetCodec.RequestParameters |
ReplicatedMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerCodec.RequestParameters |
ReplicatedMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapEntrySetCodec.RequestParameters |
ReplicatedMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapIsEmptyCodec.RequestParameters |
ReplicatedMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapKeySetCodec.RequestParameters |
ReplicatedMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapRemoveCodec.RequestParameters |
ReplicatedMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapClearCodec.RequestParameters |
ReplicatedMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerToKeyCodec.RequestParameters |
ReplicatedMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapContainsValueCodec.RequestParameters |
ReplicatedMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.RequestParameters |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapContainsKeyCodec.RequestParameters |
ReplicatedMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapAddEntryListenerWithPredicateCodec.RequestParameters |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.ReplicatedMapPutAllCodec.RequestParameters |
ReplicatedMapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
RingbufferTailSequenceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferReadOneMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferHeadSequenceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferRemainingCapacityMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferReadManyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferCapacityMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.RingbufferTailSequenceCodec.RequestParameters |
RingbufferTailSequenceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferReadOneCodec.RequestParameters |
RingbufferReadOneMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferHeadSequenceCodec.RequestParameters |
RingbufferHeadSequenceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferRemainingCapacityCodec.RequestParameters |
RingbufferRemainingCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferAddCodec.RequestParameters |
RingbufferAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferAddAllCodec.RequestParameters |
RingbufferAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferReadManyCodec.RequestParameters |
RingbufferReadManyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferSizeCodec.RequestParameters |
RingbufferSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.RingbufferCapacityCodec.RequestParameters |
RingbufferCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
RingbufferAddAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferHeadSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadManyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadOneMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferRemainingCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferTailSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
SemaphoreReleaseMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreAcquireMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreReducePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreAvailablePermitsMessageTasks.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreInitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreDrainPermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SemaphoreTryAcquireMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.SemaphoreReleaseCodec.RequestParameters |
SemaphoreReleaseMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreAcquireCodec.RequestParameters |
SemaphoreAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreReducePermitsCodec.RequestParameters |
SemaphoreReducePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreAvailablePermitsCodec.RequestParameters |
SemaphoreAvailablePermitsMessageTasks.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreInitCodec.RequestParameters |
SemaphoreInitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreDrainPermitsCodec.RequestParameters |
SemaphoreDrainPermitsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SemaphoreTryAcquireCodec.RequestParameters |
SemaphoreTryAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
SemaphoreAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreAvailablePermitsMessageTasks(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreDrainPermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreInitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReducePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreReleaseMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SemaphoreTryAcquireMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
SetContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRetainAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.SetContainsCodec.RequestParameters |
SetContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddAllCodec.RequestParameters |
SetAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetGetAllCodec.RequestParameters |
SetGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetRemoveCodec.RequestParameters |
SetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetClearCodec.RequestParameters |
SetClearMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRemoveAllCodec.RequestParameters |
SetCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetRemoveListenerCodec.RequestParameters |
SetRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetSizeCodec.RequestParameters |
SetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddListenerCodec.RequestParameters |
SetAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetContainsAllCodec.RequestParameters |
SetContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetAddCodec.RequestParameters |
SetAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetIsEmptyCodec.RequestParameters |
SetIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.SetCompareAndRetainAllCodec.RequestParameters |
SetCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TopicRemoveMessageListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicPublishMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicAddMessageListenerMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TopicRemoveMessageListenerCodec.RequestParameters |
TopicRemoveMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TopicPublishCodec.RequestParameters |
TopicPublishMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec.RequestParameters |
TopicAddMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicPublishMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
XATransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAClearRemoteTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCommitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAFinalizeTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionPrepareMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XACollectTransactionsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionCommitMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.XATransactionCreateCodec.RequestParameters |
XATransactionCreateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionRollbackCodec.RequestParameters |
XATransactionRollbackMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionClearRemoteCodec.RequestParameters |
XAClearRemoteTransactionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionCommitCodec.RequestParameters |
TransactionCommitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionFinalizeCodec.RequestParameters |
XAFinalizeTransactionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionPrepareCodec.RequestParameters |
XATransactionPrepareMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionCollectTransactionsCodec.RequestParameters |
XACollectTransactionsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionRollbackCodec.RequestParameters |
TransactionRollbackMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionCreateCodec.RequestParameters |
TransactionCreateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.XATransactionCommitCodec.RequestParameters |
XATransactionCommitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalListAddCodec.RequestParameters |
TransactionalListAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalListRemoveCodec.RequestParameters |
TransactionalListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalListSizeCodec.RequestParameters |
TransactionalListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalListAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMapValuesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetForUpdateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapIsEmptyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesWithPredicateCodec.RequestParameters |
TransactionalMapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceIfSameCodec.RequestParameters |
TransactionalMapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapValuesCodec.RequestParameters |
TransactionalMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetCodec.RequestParameters |
TransactionalMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapKeySetWithPredicateCodec.RequestParameters |
TransactionalMapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapContainsKeyCodec.RequestParameters |
TransactionalMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapDeleteCodec.RequestParameters |
TransactionalMapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSizeCodec.RequestParameters |
TransactionalMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutIfAbsentCodec.RequestParameters |
TransactionalMapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapSetCodec.RequestParameters |
TransactionalMapSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveIfSameCodec.RequestParameters |
TransactionalMapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapPutCodec.RequestParameters |
TransactionalMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetCodec.RequestParameters |
TransactionalMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapGetForUpdateCodec.RequestParameters |
TransactionalMapGetForUpdateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapReplaceCodec.RequestParameters |
TransactionalMapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapRemoveCodec.RequestParameters |
TransactionalMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMapIsEmptyCodec.RequestParameters |
TransactionalMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapValueCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapPutCodec.RequestParameters |
TransactionalMultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapSizeCodec.RequestParameters |
TransactionalMultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapGetCodec.RequestParameters |
TransactionalMultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveEntryCodec.RequestParameters |
TransactionalMultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapRemoveCodec.RequestParameters |
TransactionalMultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalMultiMapValueCountCodec.RequestParameters |
TransactionalMultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalMultiMapGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapPutMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveEntryMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapValueCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalQueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueOfferMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePollCodec.RequestParameters |
TransactionalQueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueTakeCodec.RequestParameters |
TransactionalQueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueSizeCodec.RequestParameters |
TransactionalQueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueuePeekCodec.RequestParameters |
TransactionalQueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalQueueOfferCodec.RequestParameters |
TransactionalQueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalQueueOfferMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePeekMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePollMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueTakeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalSetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetRemoveCodec.RequestParameters |
TransactionalSetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetAddCodec.RequestParameters |
TransactionalSetAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected com.hazelcast.client.impl.protocol.codec.TransactionalSetSizeCodec.RequestParameters |
TransactionalSetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalSetAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
ClientMessageBuilder.MessageHandler.handleMessage(ClientMessage message)
Received message to be processed
|
Modifier and Type | Method and Description |
---|---|
protected <T> T |
ClientRingbufferProxy.invoke(ClientMessage clientMessage,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
void |
ClientInvocationService.handleClientMessage(ClientMessage message,
Connection connection) |
protected <T> T |
ClientProxy.invoke(ClientMessage clientMessage) |
protected <T> T |
ClientProxy.invoke(ClientMessage clientMessage,
Object key) |
protected <T> T |
ClientProxy.invokeOnPartition(ClientMessage clientMessage,
int partitionId) |
protected <T> T |
ClientProxy.invokeOnPartitionInterruptibly(ClientMessage clientMessage,
int partitionId) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
ClientInvocationFuture.clientMessage |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ListenerMessageCodec.encodeAddRequest(boolean localOnly) |
ClientMessage |
ListenerMessageCodec.encodeRemoveRequest(String realRegistrationId) |
ClientMessage |
ClientInvocationFuture.get() |
ClientMessage |
ClientInvocationFuture.get(long timeout,
TimeUnit unit) |
ClientMessage |
ClientInvocation.getClientMessage() |
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) |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Address address) |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Connection connection) |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
int partitionId) |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
int partitionId,
Address address,
Connection connection) |
ClientInvocationFuture(ClientInvocation invocation,
HazelcastClientInstanceImpl client,
ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
void |
ClientListenerServiceImpl.handleClientMessage(ClientMessage clientMessage,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
NodeIOService.handleClientMessage(ClientMessage cm,
Connection connection) |
void |
IOService.handleClientMessage(ClientMessage cm,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
NewClientReadHandler.handleMessage(ClientMessage message) |
boolean |
NewClientWriteHandler.onWrite(ClientMessage frame,
ByteBuffer dst) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.