|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ClientMessage | |
---|---|
com.hazelcast.cache.impl.client | Hazelcast JSR-107 aka JCache implementation Client Requests |
com.hazelcast.client.impl | Contains most of the client side HazelcastInstance implementation functionality. |
com.hazelcast.client.impl.client | This contains the Requests and other DTO's exchanged between client/server |
com.hazelcast.client.impl.protocol | Client protocol related private implementation classes |
com.hazelcast.client.impl.protocol.parameters | Client protocol parameter implementations for client requests and responses |
com.hazelcast.client.impl.protocol.task | Client tasks associated with requests. |
com.hazelcast.client.impl.protocol.task.atomiclong | Client protocol tasks implementations for AtomicLong |
com.hazelcast.client.impl.protocol.task.atomicreference | Client protocol tasks implementations for AtomicReference |
com.hazelcast.client.impl.protocol.task.cache | Client protocol tasks implementations for JCache |
com.hazelcast.client.impl.protocol.task.condition | Client protocol tasks implementations for Condition |
com.hazelcast.client.impl.protocol.task.countdownlatch | Client protocol tasks implementations for CountDownLatch |
com.hazelcast.client.impl.protocol.task.executorservice | Client protocol tasks implementations for ExecutorService |
com.hazelcast.client.impl.protocol.task.list | Client protocol tasks implementations for List |
com.hazelcast.client.impl.protocol.task.lock | Client protocol tasks implementations for ILock |
com.hazelcast.client.impl.protocol.task.map | Client protocol tasks implementations for map |
com.hazelcast.client.impl.protocol.task.mapreduce | Client protocol tasks implementations for map reduce |
com.hazelcast.client.impl.protocol.task.multimap | Client protocol tasks implementations for multi map |
com.hazelcast.client.impl.protocol.task.queue | Client protocol tasks implementations for Queue |
com.hazelcast.client.impl.protocol.task.replicatedmap | Client protocol tasks implementations for ReplicatedMap |
com.hazelcast.client.impl.protocol.task.semaphore | Client protocol tasks implementations for Semaphore |
com.hazelcast.client.impl.protocol.task.set | Client protocol tasks implementations for set |
com.hazelcast.client.impl.protocol.task.topic | Client protocol tasks implementations for Topic |
com.hazelcast.client.impl.protocol.task.transaction | Client protocol tasks implementations for Transaction related |
com.hazelcast.client.impl.protocol.task.transactionallist | Client protocol tasks implementations for Transactional List |
com.hazelcast.client.impl.protocol.task.transactionalmap | Client protocol tasks implementations for Transactional Map |
com.hazelcast.client.impl.protocol.task.transactionalmultimap | Client protocol tasks implementations for Transactional MultiMap |
com.hazelcast.client.impl.protocol.task.transactionalqueue | Client protocol tasks implementations for Transactional Queue |
com.hazelcast.client.impl.protocol.task.transactionalset | Client protocol tasks implementations for Transactional Set |
com.hazelcast.client.impl.protocol.util | Protocol utils |
com.hazelcast.cluster.client | This package contains the client cluster functionality. |
com.hazelcast.collection.impl.collection.client | |
com.hazelcast.collection.impl.list.client | |
com.hazelcast.collection.impl.queue.client | This package contains client requests for the IQueue. |
com.hazelcast.collection.impl.txncollection.client | |
com.hazelcast.collection.impl.txnlist.client | |
com.hazelcast.collection.impl.txnqueue.client | |
com.hazelcast.collection.impl.txnset.client | |
com.hazelcast.concurrent.atomiclong.client | This package contains client requests for the IAtomicLong. This package contains all the client request object to operate on the IAtomicLong that are send by the client. |
com.hazelcast.concurrent.atomicreference.client | This package contains client requests for the IAtomicLong. This package contains all the client request object to operate on the IAtomicLong that are send by the client. |
com.hazelcast.concurrent.countdownlatch.client | This package contains client requests for the ICountDownLatch. This package contains all the client requests object to operate on the ICountDownLatch that are send by the client. |
com.hazelcast.concurrent.lock.client | This package contains client requests for the ILock. This package contains all the client requests object to operate on the ILock that are send by the client. |
com.hazelcast.concurrent.semaphore.client | This package contains client requests for the ISemaphore. |
com.hazelcast.executor.impl.client | This package contains client requests for the IExecutorService. |
com.hazelcast.map.impl.client | Contains client requests for the IMap |
com.hazelcast.mapreduce.impl.client | This package contains request and response classes for communication between cluster members and Hazelcast native clients |
com.hazelcast.multimap.impl.client | Contains client requests for Hazelcast MultiMap module. |
com.hazelcast.nio | This package contains classes related to New IO |
com.hazelcast.partition.client | Contains client functionality for partition related information. |
com.hazelcast.replicatedmap.impl.client | This package contains classes for client communication on replicated map implementation |
com.hazelcast.topic.impl.client | This package contains client requests for the ITopic. |
com.hazelcast.transaction.client | This package contains client transaction code |
Uses of ClientMessage in com.hazelcast.cache.impl.client |
---|
Subclasses of ClientMessage in com.hazelcast.cache.impl.client | |
---|---|
class |
AbstractCacheRequest
Abstract cache request to handle a completion id registration. |
class |
CacheAddEntryListenerRequest
Client request which registers an event listener on behalf of the client and delegates the received events back to client. |
class |
CacheAddInvalidationListenerRequest
|
class |
CacheClearRequest
This client request specifically calls CacheClearOperationFactory on the server side. |
class |
CacheContainsKeyRequest
This client request specifically calls CacheContainsKeyOperation on the server side. |
class |
CacheCreateConfigRequest
This client request specifically calls CacheCreateConfigOperation on the server side. |
class |
CacheDestroyRequest
This client request specifically calls CacheDestroyOperation on the server side. |
class |
CacheEntryProcessorRequest
This client request specifically calls CacheEntryProcessorOperation on the server side. |
class |
CacheGetAllRequest
This client request specifically calls CacheGetAllOperationFactory on the server side. |
class |
CacheGetAndRemoveRequest
This client request specifically calls CacheGetAndRemoveOperation on the server side. |
class |
CacheGetAndReplaceRequest
This client request specifically calls CacheGetAndReplaceOperation on the server side. |
class |
CacheGetConfigRequest
This client request specifically calls CacheGetConfigOperation on the server side. |
class |
CacheGetRequest
This client request specifically calls CacheGetOperation on the server side. |
class |
CacheIterateRequest
This client request specifically calls CacheKeyIteratorOperation on the server side. |
class |
CacheListenerRegistrationRequest
This client request specifically calls CacheListenerRegistrationOperation on the server side. |
class |
CacheLoadAllRequest
This client request specifically calls CacheLoadAllOperationFactory on the server side. |
class |
CacheManagementConfigRequest
This client request specifically calls CacheManagementConfigOperation on the server side. |
class |
CachePutIfAbsentRequest
This client request specifically calls CachePutIfAbsentOperation on the server side. |
class |
CachePutRequest
This client request specifically calls CachePutOperation on the server side. |
class |
CacheRemoveEntryListenerRequest
Client request which unregisters the event listener on behalf of the client. |
class |
CacheRemoveInvalidationListenerRequest
Client request which unregisters the invalidation listener on behalf of the client. |
class |
CacheRemoveRequest
This client request specifically calls CacheRemoveOperation on the server side. |
class |
CacheReplaceRequest
This client request specifically calls CacheReplaceOperation on the server side. |
class |
CacheSizeRequest
This client request specifically calls CacheSizeOperationFactory on the server side. |
Uses of ClientMessage in com.hazelcast.client.impl |
---|
Methods in com.hazelcast.client.impl with parameters of type ClientMessage | |
---|---|
void |
ClientEngineImpl.handleClientMessage(ClientMessage clientMessage,
Connection connection)
|
void |
ClientEndpointImpl.sendClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.client |
---|
Subclasses of ClientMessage in com.hazelcast.client.impl.client | |
---|---|
class |
AllPartitionsClientRequest
Base class for client request that will run on all partitions. |
class |
AuthenticationRequest
Client Authentication Request that holds credentials |
class |
BaseClientRemoveListenerRequest
|
class |
CallableClientRequest
|
class |
ClientCreateRequest
|
class |
ClientDestroyRequest
|
class |
ClientRequest
|
class |
DistributedObjectListenerRequest
|
class |
GetDistributedObjectsRequest
|
class |
GetMemberListRequest
Returns member list to client |
class |
InvocationClientRequest
|
class |
KeyBasedClientRequest
|
class |
MultiPartitionClientRequest
|
class |
MultiTargetClientRequest
Base class for client request that will be send more than one member |
class |
PartitionClientRequest
Base class for partition based client request. |
class |
RemoveAllListeners
When a connection does not respond to heart-beat we switch the listeners to another endpoint If somehow connection starts to respond heart-beat we need to signal the endpoint to remove the listeners An internal request should not be used for user calls. |
class |
RemoveDistributedObjectListenerRequest
Client request to add a distributed object listener to a remote node. |
class |
TargetClientRequest
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol |
---|
Methods in com.hazelcast.client.impl.protocol that return ClientMessage | |
---|---|
ClientMessage |
ClientMessage.addFlag(short flags)
Sets the flags field value. |
static ClientMessage |
ClientMessage.create()
|
static ClientMessage |
ClientMessage.createForDecode(byte[] buffer,
int offset,
int length)
|
static ClientMessage |
ClientMessage.createForDecode(int initialCapacity)
|
static ClientMessage |
ClientMessage.createForDecode(MutableDirectBuffer buffer,
int offset)
|
static ClientMessage |
ClientMessage.createForEncode(byte[] buffer,
int offset,
int length)
|
static ClientMessage |
ClientMessage.createForEncode(int initialCapacity)
|
ClientMessage |
ClientMessage.getPayloadData(byte[] payload)
Reads from the ClientMessage payload data region and writes into the payload array. |
ClientMessage |
ClientMessage.putPayloadData(byte[] payload)
Copy data into the payload data region located at data Offset. |
ClientMessage |
ClientMessage.setCorrelationId(int correlationId)
Sets the correlation id field. |
ClientMessage |
ClientMessage.setDataOffset(int dataOffset)
Sets the dataOffset field. |
ClientMessage |
ClientMessage.setFrameLength(int length)
Sets the frame length field. |
ClientMessage |
ClientMessage.setMessageType(int type)
Sets the message type field. |
ClientMessage |
ClientMessage.setPartitionId(int partitionId)
Sets the partition id field. |
ClientMessage |
ClientMessage.setVersion(short version)
Sets the version field value. |
ClientMessage |
ClientMessage.updateFrameLength()
|
Methods in com.hazelcast.client.impl.protocol with parameters of type ClientMessage | |
---|---|
MessageTask |
MessageTaskFactory.create(ClientMessage clientMessage,
Connection connection)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.parameters |
---|
Methods in com.hazelcast.client.impl.protocol.parameters that return ClientMessage | |
---|---|
static ClientMessage |
RemoveAllListenersParameters.encode()
|
static ClientMessage |
AddPartitionLostListenerParameters.encode()
|
static ClientMessage |
AddDistributedObjectListenerParameters.encode()
|
static ClientMessage |
GetPartitionsParameters.encode()
|
static ClientMessage |
VoidResultParameters.encode()
|
static ClientMessage |
PingParameters.encode()
|
static ClientMessage |
XACollectTransactionsParameters.encode()
|
static ClientMessage |
RegisterMembershipListenerParameters.encode()
|
static ClientMessage |
GetDistributedObjectParameters.encode()
|
static ClientMessage |
GetPartitionsResultParameters.encode(Address[] addresses,
int[] ownerIndexes)
|
static ClientMessage |
AuthenticationResultParameters.encode(Address address,
String uuid,
String ownerUuid)
|
static ClientMessage |
BooleanResultParameters.encode(boolean result)
|
static ClientMessage |
AuthenticationCustomCredentialsParameters.encode(byte[] credentials,
String uuid,
String ownerUuid,
boolean isOwnerConnection)
Encode parameters into byte array, i.e. |
static ClientMessage |
DataCollectionResultParameters.encode(Collection<Data> result)
|
static ClientMessage |
GetDistributedObjectResultParameters.encode(Collection<DistributedObjectInfo> infoCollection)
|
static ClientMessage |
MemberListResultParameters.encode(Collection<MemberImpl> members)
|
static ClientMessage |
GenericResultParameters.encode(Data result)
|
static ClientMessage |
XAClearRemoteTransactionParameters.encode(Data xidData)
|
static ClientMessage |
XAFinalizeTransactionParameters.encode(Data xidData,
boolean isCommit)
|
static ClientMessage |
EntryEventParameters.encode(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
String uuid,
int numberOfAffectedEntries)
|
static ClientMessage |
TopicEventParameters.encode(Data message,
long publishTime,
String uuid)
|
static ClientMessage |
ItemEventParameters.encode(Data item,
String uuid,
ItemEventType eventType)
|
static ClientMessage |
IntResultParameters.encode(int result)
|
static ClientMessage |
PartitionLostEventParameters.encode(int partitionId,
int lostBackupCount,
Address source)
|
static ClientMessage |
MapPartitionLostEventParameters.encode(int partitionId,
String uuid)
|
static ClientMessage |
MapReduceJobProcessInformationResultParameters.encode(JobPartitionState[] partitionStates,
int processedRecords)
|
static ClientMessage |
DataEntryListResultParameters.encode(List<Data> keys,
List<Data> values)
|
static ClientMessage |
LongResultParameters.encode(long result)
|
static ClientMessage |
TransactionCreateParameters.encode(long timeout,
int durability,
int transactionType,
long threadId)
|
static ClientMessage |
MapDataDataResultParameters.encode(Map<Data,Data> map)
|
static ClientMessage |
DataEntryListResultParameters.encode(Map<Data,Data> map)
|
static ClientMessage |
MapIntBooleanResultParameters.encode(Map<Integer,Boolean> map)
|
static ClientMessage |
MapIntDataResultParameters.encode(Map<Integer,Data> map)
|
static ClientMessage |
MemberResultParameters.encode(MemberImpl member,
int eventType)
|
static ClientMessage |
MemberAttributeChangeResultParameters.encode(MemberImpl member,
MemberAttributeChange memberAttributeChange)
|
static ClientMessage |
XATransactionCreateParameters.encode(SerializableXID xid,
long timeout)
|
static ClientMessage |
EntryViewParameters.encode(SimpleEntryView<Data,Data> dataEntryView)
|
static ClientMessage |
TransactionCreateResultParameters.encode(String transactionId)
|
static ClientMessage |
RemovePartitionLostListenerParameters.encode(String registrationId)
|
static ClientMessage |
XATransactionRollbackParameters.encode(String transactionId)
|
static ClientMessage |
RemoveDistributedObjectListenerParameters.encode(String registrationId)
|
static ClientMessage |
AddListenerResultParameters.encode(String registrationId)
|
static ClientMessage |
XATransactionPrepareParameters.encode(String transactionId)
|
static ClientMessage |
XATransactionCommitParameters.encode(String transactionId,
boolean onePhase)
|
static ClientMessage |
TransactionRollbackParameters.encode(String transactionId,
long threadId)
|
static ClientMessage |
TransactionCommitParameters.encode(String transactionId,
long threadId,
boolean prepareAndCommit)
|
static ClientMessage |
DestroyProxyParameters.encode(String name,
String serviceName)
|
static ClientMessage |
CreateProxyParameters.encode(String name,
String serviceName)
|
static ClientMessage |
DistributedObjectEventParameters.encode(String name,
String serviceName,
DistributedObjectEvent.EventType eventType)
|
static ClientMessage |
ExceptionResultParameters.encode(String className,
String causeClassName,
String message,
String stacktrace)
|
static ClientMessage |
AuthenticationParameters.encode(String username,
String password,
String uuid,
String ownerUuid,
boolean isOwnerConnection)
Encode parameters into byte array, i.e. |
Methods in com.hazelcast.client.impl.protocol.parameters with parameters of type ClientMessage | |
---|---|
static GetDistributedObjectResultParameters |
GetDistributedObjectResultParameters.decode(ClientMessage flyweight)
|
static BooleanResultParameters |
BooleanResultParameters.decode(ClientMessage flyweight)
|
static RemoveAllListenersParameters |
RemoveAllListenersParameters.decode(ClientMessage flyweight)
|
static TransactionCreateResultParameters |
TransactionCreateResultParameters.decode(ClientMessage flyweight)
|
static RemovePartitionLostListenerParameters |
RemovePartitionLostListenerParameters.decode(ClientMessage flyweight)
|
static MemberImpl |
MemberCodec.decode(ClientMessage clientMessage)
|
static MemberListResultParameters |
MemberListResultParameters.decode(ClientMessage clientMessage)
|
static XATransactionRollbackParameters |
XATransactionRollbackParameters.decode(ClientMessage clientMessage)
|
static AddPartitionLostListenerParameters |
AddPartitionLostListenerParameters.decode(ClientMessage flyweight)
|
static GenericResultParameters |
GenericResultParameters.decode(ClientMessage flyweight)
|
static AddDistributedObjectListenerParameters |
AddDistributedObjectListenerParameters.decode(ClientMessage flyweight)
|
static XAFinalizeTransactionParameters |
XAFinalizeTransactionParameters.decode(ClientMessage clientMessage)
|
static GetPartitionsParameters |
GetPartitionsParameters.decode(ClientMessage flyweight)
|
static MapIntBooleanResultParameters |
MapIntBooleanResultParameters.decode(ClientMessage clientMessage)
|
static TransactionRollbackParameters |
TransactionRollbackParameters.decode(ClientMessage clientMessage)
|
static XAClearRemoteTransactionParameters |
XAClearRemoteTransactionParameters.decode(ClientMessage clientMessage)
|
static Address |
AddressCodec.decode(ClientMessage clientMessage)
|
static DistributedObjectInfo |
DistributedObjectInfoCodec.decode(ClientMessage clientMessage)
|
static MapDataDataResultParameters |
MapDataDataResultParameters.decode(ClientMessage flyweight)
|
static AuthenticationParameters |
AuthenticationParameters.decode(ClientMessage flyweight)
Decode input byte array data into parameters |
static VoidResultParameters |
VoidResultParameters.decode(ClientMessage flyweight)
|
static MapReduceJobProcessInformationResultParameters |
MapReduceJobProcessInformationResultParameters.decode(ClientMessage flyweight)
|
static IntResultParameters |
IntResultParameters.decode(ClientMessage flyweight)
|
static XATransactionCommitParameters |
XATransactionCommitParameters.decode(ClientMessage clientMessage)
|
static LongResultParameters |
LongResultParameters.decode(ClientMessage flyweight)
|
static GetPartitionsResultParameters |
GetPartitionsResultParameters.decode(ClientMessage flyweight)
|
static ExceptionResultParameters |
ExceptionResultParameters.decode(ClientMessage flyweight)
|
static AuthenticationCustomCredentialsParameters |
AuthenticationCustomCredentialsParameters.decode(ClientMessage flyweight)
Decode input byte array data into parameters |
static DestroyProxyParameters |
DestroyProxyParameters.decode(ClientMessage flyweight)
|
static MemberAttributeChange |
MemberAttributeChangeCodec.decode(ClientMessage clientMessage)
|
static DataEntryListResultParameters |
DataEntryListResultParameters.decode(ClientMessage flyweight)
|
static RemoveDistributedObjectListenerParameters |
RemoveDistributedObjectListenerParameters.decode(ClientMessage flyweight)
|
static MapIntDataResultParameters |
MapIntDataResultParameters.decode(ClientMessage clientMessage)
|
static XATransactionCreateParameters |
XATransactionCreateParameters.decode(ClientMessage clientMessage)
|
static PingParameters |
PingParameters.decode(ClientMessage flyweight)
|
static AddListenerResultParameters |
AddListenerResultParameters.decode(ClientMessage flyweight)
|
static XACollectTransactionsParameters |
XACollectTransactionsParameters.decode(ClientMessage clientMessage)
|
static XATransactionPrepareParameters |
XATransactionPrepareParameters.decode(ClientMessage clientMessage)
|
static DistributedObjectEventParameters |
DistributedObjectEventParameters.decode(ClientMessage flyweight)
|
static PartitionLostEventParameters |
PartitionLostEventParameters.decode(ClientMessage flyweight)
|
static RegisterMembershipListenerParameters |
RegisterMembershipListenerParameters.decode(ClientMessage flyweight)
|
static TransactionCreateParameters |
TransactionCreateParameters.decode(ClientMessage clientMessage)
|
static AuthenticationResultParameters |
AuthenticationResultParameters.decode(ClientMessage flyweight)
|
static ItemEventParameters |
ItemEventParameters.decode(ClientMessage flyweight)
|
static DataCollectionResultParameters |
DataCollectionResultParameters.decode(ClientMessage flyweight)
|
static MemberResultParameters |
MemberResultParameters.decode(ClientMessage clientMessage)
|
static CreateProxyParameters |
CreateProxyParameters.decode(ClientMessage flyweight)
|
static SerializableXID |
SerializableXIDCodec.decode(ClientMessage clientMessage)
|
static EntryEventParameters |
EntryEventParameters.decode(ClientMessage flyweight)
|
static MemberAttributeChangeResultParameters |
MemberAttributeChangeResultParameters.decode(ClientMessage clientMessage)
|
static TransactionCommitParameters |
TransactionCommitParameters.decode(ClientMessage clientMessage)
|
static TopicEventParameters |
TopicEventParameters.decode(ClientMessage flyweight)
|
static EntryViewParameters |
EntryViewParameters.decode(ClientMessage flyweight)
|
static MapPartitionLostEventParameters |
MapPartitionLostEventParameters.decode(ClientMessage flyweight)
|
static GetDistributedObjectParameters |
GetDistributedObjectParameters.decode(ClientMessage flyweight)
|
static void |
AddressCodec.encode(Address address,
ClientMessage clientMessage)
|
static void |
DistributedObjectInfoCodec.encode(DistributedObjectInfo info,
ClientMessage clientMessage)
|
static void |
MemberAttributeChangeCodec.encode(MemberAttributeChange memberAttributeChange,
ClientMessage clientMessage)
|
static void |
MemberCodec.encode(MemberImpl member,
ClientMessage clientMessage)
|
static void |
SerializableXIDCodec.encode(SerializableXID xid,
ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.parameters with parameters of type ClientMessage | |
---|---|
MemberAttributeChangeResultParameters(ClientMessage clientMessage)
|
|
MemberListResultParameters(ClientMessage clientMessage)
|
|
MemberResultParameters(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task |
---|
Fields in com.hazelcast.client.impl.protocol.task declared as ClientMessage | |
---|---|
protected ClientMessage |
AbstractMessageTask.clientMessage
|
Methods in com.hazelcast.client.impl.protocol.task that return ClientMessage | |
---|---|
protected ClientMessage |
AbstractTransactionalMessageTask.call()
|
protected ClientMessage |
PingMessageTask.call()
|
protected ClientMessage |
AddDistributedObjectListenerMessageTask.call()
|
protected abstract ClientMessage |
AbstractCallableMessageTask.call()
|
protected ClientMessage |
RemovePartitionLostListenerMessageTask.call()
|
protected ClientMessage |
GetPartitionsMessageTask.call()
|
protected ClientMessage |
GetDistributedObjectMessageTask.call()
|
protected ClientMessage |
RemoveAllListenersMessageTask.call()
|
protected ClientMessage |
DestroyProxyMessageTask.call()
|
ClientMessage |
AuthenticationBaseMessageTask.call()
|
protected ClientMessage |
RegisterMembershipListenerMessageTask.call()
|
protected ClientMessage |
AbstractMultiPartitionMessageTask.call()
|
protected ClientMessage |
AddPartitionLostListenerMessageTask.call()
|
protected ClientMessage |
RemoveDistrubtedObjectListenerMessageTask.call()
|
protected ClientMessage |
CreateProxyMessageTask.call()
|
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected ClientMessage |
AbstractPartitionMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
InvocationMessageTask.encodeResponse(Object response)
|
protected abstract ClientMessage |
AbstractTransactionalMessageTask.innerCall()
|
protected abstract ClientMessage |
AbstractMultiTargetMessageTask.reduce(Map<Address,Object> map)
|
protected abstract ClientMessage |
AbstractAllPartitionsMessageTask.reduce(Map<Integer,Object> map)
|
protected abstract ClientMessage |
AbstractMultiPartitionMessageTask.reduce(Map<Integer,Object> map)
|
Methods in com.hazelcast.client.impl.protocol.task with parameters of type ClientMessage | |
---|---|
protected PingParameters |
PingMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected AddDistributedObjectListenerParameters |
AddDistributedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected RemovePartitionLostListenerParameters |
RemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected GetPartitionsParameters |
GetPartitionsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected AuthenticationParameters |
AuthenticationMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected GetDistributedObjectParameters |
GetDistributedObjectMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected RemoveAllListenersParameters |
RemoveAllListenersMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected DestroyProxyParameters |
DestroyProxyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected RegisterMembershipListenerParameters |
RegisterMembershipListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected AddPartitionLostListenerParameters |
AddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected AuthenticationCustomCredentialsParameters |
AuthenticationCustomCredentialsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected abstract P |
AbstractMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected RemoveDistributedObjectListenerParameters |
RemoveDistrubtedObjectListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected CreateProxyParameters |
CreateProxyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected void |
AbstractMessageTask.sendClientMessage(ClientMessage resultClientMessage)
|
protected void |
AbstractMessageTask.sendClientMessage(Object key,
ClientMessage resultClientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.atomiclong |
---|
Methods in com.hazelcast.client.impl.protocol.task.atomiclong that return ClientMessage | |
---|---|
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)
|
Methods in com.hazelcast.client.impl.protocol.task.atomiclong with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongGetAndSetParameters |
AtomicLongGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongAlterAndGetParameters |
AtomicLongAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongGetAndAddParameters |
AtomicLongGetAndAddMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongDecrementAndGetParameters |
AtomicLongDecrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongApplyParameters |
AtomicLongApplyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongAlterParameters |
AtomicLongAlterMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongAddAndGetParameters |
AtomicLongAddAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongCompareAndSetParameters |
AtomicLongCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongGetAndIncrementParameters |
AtomicLongGetAndIncrementMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongGetParameters |
AtomicLongGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongGetAndAlterParameters |
AtomicLongGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongIncrementAndGetParameters |
AtomicLongIncrementAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicLongSetParameters |
AtomicLongSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.atomicreference |
---|
Methods in com.hazelcast.client.impl.protocol.task.atomicreference with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceCompareAndSetParameters |
AtomicReferenceCompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceAlterAndGetParameters |
AtomicReferenceAlterAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceGetAndAlterParameters |
AtomicReferenceGetAndAlterMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceSetAndGetParameters |
AtomicReferenceSetAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceGetAndSetParameters |
AtomicReferenceGetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceGetParameters |
AtomicReferenceGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceIsNullParameters |
AtomicReferenceIsNullMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceAlterParameters |
AtomicReferenceAlterMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceSetParameters |
AtomicReferenceSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceApplyParameters |
AtomicReferenceApplyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceClearParameters |
AtomicReferenceClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.AtomicReferenceContainsParameters |
AtomicRefenceContainsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.cache |
---|
Methods in com.hazelcast.client.impl.protocol.task.cache that return ClientMessage | |
---|---|
protected ClientMessage |
CacheAddEntryListenerMessageTask.call()
|
protected ClientMessage |
CacheRemoveEntryListenerMessageTask.call()
|
protected ClientMessage |
CacheAddInvalidationListenerTask.call()
|
protected ClientMessage |
CacheRemoveInvalidationListenerMessageTask.call()
|
protected ClientMessage |
CacheLoadAllMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
CacheSizeMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
CacheGetAllMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
CacheRemoveAllMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
CacheClearMessageTask.reduce(Map<Integer,Object> map)
|
Methods in com.hazelcast.client.impl.protocol.task.cache with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.CacheDestroyParameters |
CacheDestroyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheIterateParameters |
CacheIterateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheLoadAllParameters |
CacheLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheGetParameters |
CacheGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheListenerRegistrationParameters |
CacheListenerRegistrationMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheEntryProcessorParameters |
CacheEntryProcessorMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheAddEntryListenerParameters |
CacheAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CachePutIfAbsentParameters |
CachePutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheRemoveEntryListenerParameters |
CacheRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheSizeParameters |
CacheSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheGetAndReplaceParameters |
CacheGetAndReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CachePutParameters |
CachePutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheAddInvalidationListenerParameters |
CacheAddInvalidationListenerTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheGetAllParameters |
CacheGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheRemoveParameters |
CacheRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheReplaceParameters |
CacheReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheContainsKeyParameters |
CacheContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheCreateConfigParameters |
CacheCreateConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheGetConfigParameters |
CacheGetConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheRemoveInvalidationListenerParameters |
CacheRemoveInvalidationListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheGetAndRemoveParameters |
CacheGetAndRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheRemoveAllParameters |
CacheRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheClearParameters |
CacheClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CacheManagementConfigParameters |
CacheManagementConfigMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.condition |
---|
Methods in com.hazelcast.client.impl.protocol.task.condition that return ClientMessage | |
---|---|
protected ClientMessage |
ConditionSignalAllMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ConditionSignalMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ConditionAwaitMessageTask.encodeResponse(Object response)
|
Methods in com.hazelcast.client.impl.protocol.task.condition with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.ConditionSignalAllParameters |
ConditionSignalAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ConditionBeforeAwaitParameters |
ConditionBeforeAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ConditionSignalParameters |
ConditionSignalMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ConditionAwaitParameters |
ConditionAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.condition with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.countdownlatch |
---|
Methods in com.hazelcast.client.impl.protocol.task.countdownlatch that return ClientMessage | |
---|---|
protected ClientMessage |
CountDownLatchGetCountMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
CountDownLatchAwaitMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
CountDownLatchTrySetCountMessageTask.encodeResponse(Object response)
|
Methods in com.hazelcast.client.impl.protocol.task.countdownlatch with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.CountDownLatchGetCountParameters |
CountDownLatchGetCountMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CountDownLatchAwaitParameters |
CountDownLatchAwaitMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CountDownLatchCountDownParameters |
CountDownLatchCountDownMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.CountDownLatchTrySetCountParameters |
CountDownLatchTrySetCountMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.countdownlatch with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.executorservice |
---|
Methods in com.hazelcast.client.impl.protocol.task.executorservice that return ClientMessage | |
---|---|
protected ClientMessage |
ExecutorServiceIsShutdownMessageTask.call()
|
protected ClientMessage |
ExecutorServiceShutdownMessageTask.call()
|
protected ClientMessage |
AbstractExecutorServiceCancelMessageTask.call()
|
Methods in com.hazelcast.client.impl.protocol.task.executorservice with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.ExecutorServiceIsShutdownParameters |
ExecutorServiceIsShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ExecutorServiceShutdownParameters |
ExecutorServiceShutdownMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ExecutorServiceCancelOnPartitionParameters |
ExecutorServiceCancelOnPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ExecutorServiceSubmitToPartitionParameters |
ExecutorServiceSubmitToPartitionMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ExecutorServiceCancelOnAddressParameters |
ExecutorServiceCancelOnAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ExecutorServiceSubmitToAddressParameters |
ExecutorServiceSubmitToAddressMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.executorservice with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.list |
---|
Methods in com.hazelcast.client.impl.protocol.task.list that return ClientMessage | |
---|---|
protected ClientMessage |
ListRemoveListenerMessageTask.call()
|
protected ClientMessage |
ListAddListenerMessageTask.call()
|
protected ClientMessage |
ListIteratorMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListIndexOfMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListLastIndexOfMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListAddMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListRemoveMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListCompareAndRetainAllMessageTask.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 |
ListGetAllMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListAddAllMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListContainsAllMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
ListAddAllWithIndexMessageTask.encodeResponse(Object response)
|
Methods in com.hazelcast.client.impl.protocol.task.list with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.ListIteratorParameters |
ListIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListIndexOfParameters |
ListIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListGetParameters |
ListGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListLastIndexOfParameters |
ListLastIndexOfMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListAddParameters |
ListAddMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListRemoveParameters |
ListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListCompareAndRetainAllParameters |
ListCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListRemoveListenerParameters |
ListRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListIsEmptyParameters |
ListIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListCompareAndRemoveAllParameters |
ListCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListSizeParameters |
ListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListContainsParameters |
ListContainsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListAddWithIndexParameters |
ListAddWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListSubParameters |
ListSubMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListAddListenerParameters |
ListAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListGetAllParameters |
ListGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListRemoveWithIndexParameters |
ListRemoveWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListAddAllParameters |
ListAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListContainsAllParameters |
ListContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListAddAllWithIndexParameters |
ListAddAllWithIndexMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListSetParameters |
ListSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ListClearParameters |
ListClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.lock |
---|
Methods in com.hazelcast.client.impl.protocol.task.lock that return ClientMessage | |
---|---|
protected ClientMessage |
LockIsLockedMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
LockUnlockMessagetask.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 |
LockTryLockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
LockGetLockCountMessageTask.encodeResponse(Object response)
|
Methods in com.hazelcast.client.impl.protocol.task.lock with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.LockIsLockedParameters |
LockIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.LockUnlockParameters |
LockUnlockMessagetask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.LockGetRemainingLeaseTimeParameters |
LockGetRemainingLeaseTimeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.LockForceUnlockParameters |
LockForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.LockIsLockedByCurrentThreadParameters |
LockIsLockedByCurrentThreadMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.LockLockParameters |
LockLockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.LockTryLockParameters |
LockTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.LockGetLockCountParameters |
LockGetLockCountMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.lock with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.map |
---|
Methods in com.hazelcast.client.impl.protocol.task.map that return ClientMessage | |
---|---|
protected ClientMessage |
AbstractMapAddEntryListenerMessageTask.call()
|
protected ClientMessage |
MapAddPartitionLostListenerMessageTask.call()
|
protected ClientMessage |
MapLoadAllMessageTask.call()
|
protected ClientMessage |
MapRemovePartitionLostListenerMessageTask.call()
|
protected ClientMessage |
AbstractMapQueryMessageTask.call()
|
protected ClientMessage |
MapRemoveEntryListenerMessageTask.call()
|
protected ClientMessage |
MapTryLockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapIsLockedMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapDeleteMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapLockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapUnlockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapForceUnlockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapGetEntryViewMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapSetMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapContainsKeyMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapReplaceIfSameMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapTryPutMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapTryRemoveMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapRemoveIfSameMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapEvictMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MapEntriesWithPredicateMessageTask.reduce(Collection<QueryResultEntry> result)
|
protected abstract ClientMessage |
AbstractMapQueryMessageTask.reduce(Collection<QueryResultEntry> result)
|
protected ClientMessage |
MapKeySetWithPredicateMessageTask.reduce(Collection<QueryResultEntry> result)
|
protected ClientMessage |
MapValuesWithPredicateMessageTask.reduce(Collection<QueryResultEntry> result)
|
protected ClientMessage |
MapAddInterceptorMessageTask.reduce(Map<Address,Object> map)
|
protected ClientMessage |
MapRemoveInterceptorMessageTask.reduce(Map<Address,Object> map)
|
protected ClientMessage |
MapPutAllMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapAddIndexMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapFlushMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapExecuteOnKeysMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapKeySetMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapGetAllMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapSizeMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapExecuteOnAllKeysMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapValuesMessageTask.reduce(Map<Integer,Object> results)
|
protected ClientMessage |
MapClearMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapLoadGivenKeysMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapExecuteWithPredicateMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapEntrySetMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapContainsValueMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapEvictAllMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MapIsEmptyMessageTask.reduce(Map<Integer,Object> map)
|
Methods in com.hazelcast.client.impl.protocol.task.map with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.MapPutAllParameters |
MapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddEntryListenerToKeyWithPredicateParameters |
MapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapGetParameters |
MapGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddIndexParameters |
MapAddIndexMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapFlushParameters |
MapFlushMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapExecuteOnKeysParameters |
MapExecuteOnKeysMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReplaceParameters |
MapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapKeySetParameters |
MapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapGetAllParameters |
MapGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapEntriesWithPredicateParameters |
MapEntriesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapTryLockParameters |
MapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddPartitionLostListenerParameters |
MapAddPartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapIsLockedParameters |
MapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapPutAsyncParameters |
MapPutAsyncMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapLoadAllParameters |
MapLoadAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapDeleteParameters |
MapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapSizeParameters |
MapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddInterceptorParameters |
MapAddInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapRemoveInterceptorParameters |
MapRemoveInterceptorMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapGetAsyncParameters |
MapGetAsyncMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapLockParameters |
MapLockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapUnlockParameters |
MapUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapPutTransientParameters |
MapPutTransientMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapForceUnlockParameters |
MapForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapRemoveAsyncParameters |
MapRemoveAsyncMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapGetEntryViewParameters |
MapGetEntryViewMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapSetParameters |
MapSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapExecuteOnAllKeysParameters |
MapExecuteOnAllKeysMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapValuesParameters |
MapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapRemovePartitionLostListenerParameters |
MapRemovePartitionLostListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapClearParameters |
MapClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapLoadGivenKeysParameters |
MapLoadGivenKeysMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapContainsKeyParameters |
MapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapPutIfAbsentParameters |
MapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapKeySetWithPredicateParameters |
MapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapPutParameters |
MapPutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapExecuteWithPredicateParameters |
MapExecuteWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapEntrySetParameters |
MapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapContainsValueParameters |
MapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddNearCacheEntryListenerParameters |
MapAddNearCacheEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapSubmitToKeyParameters |
MapSubmitToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapExecuteOnKeyParameters |
MapExecuteOnKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReplaceIfSameParameters |
MapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddEntryListenerToKeyParameters |
MapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapTryPutParameters |
MapTryPutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapTryRemoveParameters |
MapTryRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddEntryListenerParameters |
MapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapEvictAllParameters |
MapEvictAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapRemoveEntryListenerParameters |
MapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapRemoveIfSameParameters |
MapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapAddEntryListenerWithPredicateParameters |
MapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapRemoveParameters |
MapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapEvictParameters |
MapEvictMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapIsEmptyParameters |
MapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapValuesWithPredicateParameters |
MapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.mapreduce |
---|
Methods in com.hazelcast.client.impl.protocol.task.mapreduce that return ClientMessage | |
---|---|
protected ClientMessage |
MapReduceCancelMessageTask.call()
|
protected ClientMessage |
MapReduceJobProcessInformationMessageTask.call()
|
protected ClientMessage |
AbstractMapReduceTask.call()
|
Methods in com.hazelcast.client.impl.protocol.task.mapreduce with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.MapReduceCancelParameters |
MapReduceCancelMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReduceForMapParameters |
MapReduceForMapMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters |
MapReduceJobProcessInformationMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReduceForSetParameters |
MapReduceForSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReduceForCustomParameters |
MapReduceForCustomMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReduceForListParameters |
MapReduceForListMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MapReduceForMultiMapParameters |
MapReduceForMultiMapMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.mapreduce with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.multimap |
---|
Methods in com.hazelcast.client.impl.protocol.task.multimap that return ClientMessage | |
---|---|
protected ClientMessage |
AbstractMultiMapAddEntryListenerMessageTask.call()
|
protected ClientMessage |
MultiMapRemoveEntryListenerMessageTask.call()
|
protected ClientMessage |
MultiMapForceUnlockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapRemoveMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapValueCountMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapUnlockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapContainsKeyMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapGetMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapIsLockedMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapContainsEntryMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapTryLockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapLockMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapPutMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapRemoveEntryMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
MultiMapContainsValueMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MultiMapValuesMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MultiMapEntrySetMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MultiMapClearMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MultiMapSizeMessageTask.reduce(Map<Integer,Object> map)
|
protected ClientMessage |
MultiMapKeySetMessageTask.reduce(Map<Integer,Object> map)
|
Methods in com.hazelcast.client.impl.protocol.task.multimap with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapAddEntryListenerToKeyParameters |
MultiMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapContainsValueParameters |
MultiMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapCountParameters |
MultiMapCountMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapValuesParameters |
MultiMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapForceUnlockParameters |
MultiMapForceUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapRemoveParameters |
MultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapValueCountParameters |
MultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapEntrySetParameters |
MultiMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapUnlockParameters |
MultiMapUnlockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapContainsKeyParameters |
MultiMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapGetParameters |
MultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapClearParameters |
MultiMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapIsLockedParameters |
MultiMapIsLockedMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapContainsEntryParameters |
MultiMapContainsEntryMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapAddEntryListenerParameters |
MultiMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapTryLockParameters |
MultiMapTryLockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapLockParameters |
MultiMapLockMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapSizeParameters |
MultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapRemoveEntryListenerParameters |
MultiMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapPutParameters |
MultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapRemoveEntryParameters |
MultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.MultiMapKeySetParameters |
MultiMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.queue |
---|
Methods in com.hazelcast.client.impl.protocol.task.queue that return ClientMessage | |
---|---|
protected ClientMessage |
QueueRemoveListenerMessageTask.call()
|
protected ClientMessage |
QueueAddListenerMessageTask.call()
|
protected ClientMessage |
QueueSizeMessageTask.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 |
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 |
QueueClearMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
QueueDrainMessageTask.encodeResponse(Object response)
|
Methods in com.hazelcast.client.impl.protocol.task.queue with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.QueuePeekParameters |
QueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueSizeParameters |
QueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueRemoveListenerParameters |
QueueRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueOfferParameters |
QueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueDrainToMaxSizeParameters |
QueueDrainMaxSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueIteratorParameters |
QueueIteratorMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueRemainingCapacityParameters |
QueueRemainingCapacityMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueAddListenerParameters |
QueueAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueIsEmptyParameters |
QueueIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueContainsParameters |
QueueContainsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueuePutParameters |
QueuePutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueRemoveParameters |
QueueRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueCompareAndRemoveAllParameters |
QueueCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueAddAllParameters |
QueueAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueCompareAndRetainAllParameters |
QueueCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueContainsAllParameters |
QueueContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueTakeParameters |
QueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueClearParameters |
QueueClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueuePollParameters |
QueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.QueueDrainToParameters |
QueueDrainMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.replicatedmap |
---|
Methods in com.hazelcast.client.impl.protocol.task.replicatedmap that return ClientMessage | |
---|---|
protected ClientMessage |
ReplicatedMapPutMessageTask.call()
|
protected ClientMessage |
ReplicatedMapSizeMessageTask.call()
|
protected ClientMessage |
ReplicatedMapRemoveEntryListenerMessageTask.call()
|
protected ClientMessage |
ReplicatedMapValuesMessageTask.call()
|
protected ClientMessage |
ReplicatedMapGetMessageTask.call()
|
protected ClientMessage |
ReplicatedMapEntrySetMessageTask.call()
|
protected ClientMessage |
ReplicatedMapIsEmptyMessageTask.call()
|
protected ClientMessage |
ReplicatedMapKeySetMessageTask.call()
|
protected ClientMessage |
ReplicatedMapRemoveMessageTask.call()
|
protected ClientMessage |
ReplicatedMapClearMessageTask.call()
|
protected ClientMessage |
AbstractReplicatedMapAddEntryListenerMessageTask.call()
|
protected ClientMessage |
ReplicatedMapContainsValueMessageTask.call()
|
protected ClientMessage |
ReplicatedMapContainsKeyMessageTask.call()
|
protected ClientMessage |
ReplicatedMapPutAllMessageTask.call()
|
Methods in com.hazelcast.client.impl.protocol.task.replicatedmap with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapPutParameters |
ReplicatedMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapSizeParameters |
ReplicatedMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapRemoveEntryListenerParameters |
ReplicatedMapRemoveEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapValuesParameters |
ReplicatedMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapGetParameters |
ReplicatedMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapAddEntryListenerParameters |
ReplicatedMapAddEntryListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapEntrySetParameters |
ReplicatedMapEntrySetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapIsEmptyParameters |
ReplicatedMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapKeySetParameters |
ReplicatedMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapRemoveParameters |
ReplicatedMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapClearParameters |
ReplicatedMapClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapAddEntryListenerToKeyParameters |
ReplicatedMapAddEntryListenerToKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapContainsValueParameters |
ReplicatedMapContainsValueMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapAddEntryListenerToKeyWithPredicateParameters |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapContainsKeyParameters |
ReplicatedMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapAddEntryListenerWithPredicateParameters |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.ReplicatedMapPutAllParameters |
ReplicatedMapPutAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.semaphore |
---|
Methods in com.hazelcast.client.impl.protocol.task.semaphore that return ClientMessage | |
---|---|
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)
|
Methods in com.hazelcast.client.impl.protocol.task.semaphore with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.SemaphoreReleaseParameters |
SemaphoreReleaseMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SemaphoreAcquireParameters |
SemaphoreAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SemaphoreReducePermitsParameters |
SemaphoreReducePermitsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SemaphoreAvailablePermitsParameters |
SemaphoreAvailablePermitsMessageTasks.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SemaphoreInitParameters |
SemaphoreInitMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SemaphoreDrainPermitsParameters |
SemaphoreDrainPermitsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SemaphoreTryAcquireParameters |
SemaphoreTryAcquireMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.semaphore with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.set |
---|
Methods in com.hazelcast.client.impl.protocol.task.set that return ClientMessage | |
---|---|
protected ClientMessage |
SetRemoveListenerMessageTask.call()
|
protected ClientMessage |
SetAddListenerMessageTask.call()
|
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 |
SetCompareAndRemoveAllMessageTask.encodeResponse(Object response)
|
protected ClientMessage |
SetSizeMessageTask.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)
|
Methods in com.hazelcast.client.impl.protocol.task.set with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.SetContainsParameters |
SetContainsMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetAddAllParameters |
SetAddAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetGetAllParameters |
SetGetAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetRemoveParameters |
SetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetClearParameters |
SetClearMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetCompareAndRemoveAllParameters |
SetCompareAndRemoveAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetRemoveListenerParameters |
SetRemoveListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetSizeParameters |
SetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetAddListenerParameters |
SetAddListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetContainsAllParameters |
SetContainsAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetAddParameters |
SetAddMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetIsEmptyParameters |
SetIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.SetCompareAndRetainAllParameters |
SetCompareAndRetainAllMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.topic |
---|
Methods in com.hazelcast.client.impl.protocol.task.topic that return ClientMessage | |
---|---|
protected ClientMessage |
TopicRemoveMessageListenerMessageTask.call()
|
protected ClientMessage |
TopicAddMessageListenerMessageTask.call()
|
Methods in com.hazelcast.client.impl.protocol.task.topic with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.TopicRemoveMessageListenerParameters |
TopicRemoveMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TopicPublishParameters |
TopicPublishMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TopicAddMessageListenerParameters |
TopicAddMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.topic with parameters of type ClientMessage | |
---|---|
TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
|
TopicPublishMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
|
TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.transaction |
---|
Methods in com.hazelcast.client.impl.protocol.task.transaction that return ClientMessage | |
---|---|
protected ClientMessage |
XATransactionCreateMessageTask.call()
|
protected ClientMessage |
XATransactionRollbackMessageTask.call()
|
protected ClientMessage |
XAClearRemoteTransactionMessageTask.call()
|
protected ClientMessage |
XATransactionPrepareMessageTask.call()
|
protected ClientMessage |
XATransactionCommitMessageTask.call()
|
protected ClientMessage |
TransactionCommitMessageTask.innerCall()
|
protected ClientMessage |
TransactionRollbackMessageTask.innerCall()
|
protected ClientMessage |
TransactionCreateMessageTask.innerCall()
|
protected ClientMessage |
XACollectTransactionsMessageTask.reduce(Map<Address,Object> map)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.transactionallist |
---|
Methods in com.hazelcast.client.impl.protocol.task.transactionallist that return ClientMessage | |
---|---|
protected ClientMessage |
TransactionalListAddMessageTask.innerCall()
|
protected ClientMessage |
TransactionalListRemoveMessageTask.innerCall()
|
protected ClientMessage |
TransactionalListSizeMessageTask.innerCall()
|
Methods in com.hazelcast.client.impl.protocol.task.transactionallist with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalListAddParameters |
TransactionalListAddMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalListRemoveParameters |
TransactionalListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalListSizeParameters |
TransactionalListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.transactionallist with parameters of type ClientMessage | |
---|---|
TransactionalListAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
|
TransactionalListRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
|
TransactionalListSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.transactionalmap |
---|
Methods in com.hazelcast.client.impl.protocol.task.transactionalmap that return ClientMessage | |
---|---|
protected ClientMessage |
TransactionalMapValuesWithPredicateMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapReplaceIfSameMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapValuesMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapKeySetMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapKeySetWithPredicateMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapContainsKeyMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapDeleteMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapSizeMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapPutIfAbsentMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapSetMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapRemoveIfSameMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapPutMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapGetMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapGetForUpdateMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapReplaceMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapRemoveMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMapIsEmptyMessageTask.innerCall()
|
Methods in com.hazelcast.client.impl.protocol.task.transactionalmap with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapValuesWithPredicateParameters |
TransactionalMapValuesWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapReplaceIfSameParameters |
TransactionalMapReplaceIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapValuesParameters |
TransactionalMapValuesMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapKeySetParameters |
TransactionalMapKeySetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapKeySetWithPredicateParameters |
TransactionalMapKeySetWithPredicateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapContainsKeyParameters |
TransactionalMapContainsKeyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapDeleteParameters |
TransactionalMapDeleteMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapSizeParameters |
TransactionalMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapPutIfAbsentParameters |
TransactionalMapPutIfAbsentMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapSetParameters |
TransactionalMapSetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapRemoveIfSameParameters |
TransactionalMapRemoveIfSameMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapPutParameters |
TransactionalMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapGetParameters |
TransactionalMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapGetForUpdateParameters |
TransactionalMapGetForUpdateMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapReplaceParameters |
TransactionalMapReplaceMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapRemoveParameters |
TransactionalMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMapIsEmptyParameters |
TransactionalMapIsEmptyMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.transactionalmultimap |
---|
Methods in com.hazelcast.client.impl.protocol.task.transactionalmultimap that return ClientMessage | |
---|---|
protected ClientMessage |
TransactionalMultiMapPutMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMultiMapSizeMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMultiMapGetMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMultiMapRemoveEntryMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMultiMapRemoveMessageTask.innerCall()
|
protected ClientMessage |
TransactionalMultiMapValueCountMessageTask.innerCall()
|
Methods in com.hazelcast.client.impl.protocol.task.transactionalmultimap with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMultiMapPutParameters |
TransactionalMultiMapPutMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMultiMapSizeParameters |
TransactionalMultiMapSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMultiMapGetParameters |
TransactionalMultiMapGetMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMultiMapRemoveEntryParameters |
TransactionalMultiMapRemoveEntryMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMultiMapRemoveParameters |
TransactionalMultiMapRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalMultiMapValueCountParameters |
TransactionalMultiMapValueCountMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.transactionalmultimap with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.transactionalqueue |
---|
Methods in com.hazelcast.client.impl.protocol.task.transactionalqueue that return ClientMessage | |
---|---|
protected ClientMessage |
TransactionalQueuePollMessageTask.innerCall()
|
protected ClientMessage |
TransactionalQueueTakeMessageTask.innerCall()
|
protected ClientMessage |
TransactionalQueueSizeMessageTask.innerCall()
|
protected ClientMessage |
TransactionalQueuePeekMessageTask.innerCall()
|
protected ClientMessage |
TransactionalQueueOfferMessageTask.innerCall()
|
Methods in com.hazelcast.client.impl.protocol.task.transactionalqueue with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalQueuePollParameters |
TransactionalQueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalQueueTakeParameters |
TransactionalQueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalQueueSizeParameters |
TransactionalQueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalQueuePeekParameters |
TransactionalQueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalQueueOfferParameters |
TransactionalQueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.transactionalqueue with parameters of type ClientMessage | |
---|---|
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)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.task.transactionalset |
---|
Methods in com.hazelcast.client.impl.protocol.task.transactionalset that return ClientMessage | |
---|---|
protected ClientMessage |
TransactionalSetRemoveMessageTask.innerCall()
|
protected ClientMessage |
TransactionalSetAddMessageTask.innerCall()
|
protected ClientMessage |
TransactionalSetSizeMessageTask.innerCall()
|
Methods in com.hazelcast.client.impl.protocol.task.transactionalset with parameters of type ClientMessage | |
---|---|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalSetRemoveParameters |
TransactionalSetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalSetAddParameters |
TransactionalSetAddMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
protected com.hazelcast.client.impl.protocol.parameters.TransactionalSetSizeParameters |
TransactionalSetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage)
|
Constructors in com.hazelcast.client.impl.protocol.task.transactionalset with parameters of type ClientMessage | |
---|---|
TransactionalSetAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
|
TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
|
TransactionalSetSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection)
|
Uses of ClientMessage in com.hazelcast.client.impl.protocol.util |
---|
Methods in com.hazelcast.client.impl.protocol.util with parameters of type ClientMessage | |
---|---|
static Address |
ParameterUtil.decodeAddress(ClientMessage clientMessage)
|
static void |
ParameterUtil.encodeAddress(ClientMessage clientMessage,
Address address)
|
void |
ClientMessageBuilder.MessageHandler.handleMessage(ClientMessage message)
Received message to be processed |
Uses of ClientMessage in com.hazelcast.cluster.client |
---|
Subclasses of ClientMessage in com.hazelcast.cluster.client | |
---|---|
class |
AddMembershipListenerRequest
|
class |
ClientPingRequest
|
class |
RegisterMembershipListenerRequest
|
Uses of ClientMessage in com.hazelcast.collection.impl.collection.client |
---|
Subclasses of ClientMessage in com.hazelcast.collection.impl.collection.client | |
---|---|
class |
CollectionAddAllRequest
|
class |
CollectionAddListenerRequest
this class is used to attach a listener to node for collections |
class |
CollectionAddRequest
|
class |
CollectionClearRequest
|
class |
CollectionCompareAndRemoveRequest
|
class |
CollectionContainsRequest
|
class |
CollectionGetAllRequest
|
class |
CollectionIsEmptyRequest
|
class |
CollectionRemoveListenerRequest
|
class |
CollectionRemoveRequest
|
class |
CollectionRequest
|
class |
CollectionSizeRequest
|
Uses of ClientMessage in com.hazelcast.collection.impl.list.client |
---|
Subclasses of ClientMessage in com.hazelcast.collection.impl.list.client | |
---|---|
class |
ListAddAllRequest
|
class |
ListAddRequest
|
class |
ListGetRequest
|
class |
ListIndexOfRequest
|
class |
ListRemoveRequest
|
class |
ListSetRequest
|
class |
ListSubRequest
|
Uses of ClientMessage in com.hazelcast.collection.impl.queue.client |
---|
Subclasses of ClientMessage in com.hazelcast.collection.impl.queue.client | |
---|---|
class |
AddAllRequest
Provides the request service for AddAllOperation |
class |
AddListenerRequest
this class is used to attach a listener to targeted node which sends back the events to client for a queue |
class |
CompareAndRemoveRequest
Provides the request service for CompareAndRemoveOperation |
class |
DrainRequest
Provides the request service for DrainOperation |
class |
IsEmptyRequest
Request to check if the Queue is empty |
class |
IteratorRequest
Provides the request service for IteratorOperation |
class |
OfferRequest
Provides the request service for OfferOperation |
class |
PeekRequest
Provides the request service for PeekOperation |
class |
PollRequest
Provides the request service for PollOperation |
class |
QueueRequest
This class contains methods for all Queue requests such as ClearRequest . |
class |
RemainingCapacityRequest
Request for remaining capacity of Queue. |
class |
RemoveListenerRequest
Remove listener request belong to the Queue item. |
Uses of ClientMessage in com.hazelcast.collection.impl.txncollection.client |
---|
Subclasses of ClientMessage in com.hazelcast.collection.impl.txncollection.client | |
---|---|
class |
TxnCollectionRequest
|
Uses of ClientMessage in com.hazelcast.collection.impl.txnlist.client |
---|
Subclasses of ClientMessage in com.hazelcast.collection.impl.txnlist.client | |
---|---|
class |
TxnListAddRequest
|
class |
TxnListRemoveRequest
|
class |
TxnListSizeRequest
|
Uses of ClientMessage in com.hazelcast.collection.impl.txnqueue.client |
---|
Subclasses of ClientMessage in com.hazelcast.collection.impl.txnqueue.client | |
---|---|
class |
TxnOfferRequest
Request for transactional offer operation. |
class |
TxnPeekRequest
Request for transactional peek operation. |
class |
TxnPollRequest
Request for transactional poll operation. |
class |
TxnSizeRequest
Request for size of the Transactional Queue. |
Uses of ClientMessage in com.hazelcast.collection.impl.txnset.client |
---|
Subclasses of ClientMessage in com.hazelcast.collection.impl.txnset.client | |
---|---|
class |
TxnSetAddRequest
|
class |
TxnSetRemoveRequest
|
class |
TxnSetSizeRequest
|
Uses of ClientMessage in com.hazelcast.concurrent.atomiclong.client |
---|
Subclasses of ClientMessage in com.hazelcast.concurrent.atomiclong.client | |
---|---|
class |
AddAndGetRequest
|
class |
AtomicLongRequest
|
class |
CompareAndSetRequest
|
class |
GetAndAddRequest
|
class |
GetAndSetRequest
|
class |
SetRequest
|
Uses of ClientMessage in com.hazelcast.concurrent.atomicreference.client |
---|
Subclasses of ClientMessage in com.hazelcast.concurrent.atomicreference.client | |
---|---|
class |
AbstractAlterRequest
|
class |
AlterAndGetRequest
|
class |
AlterRequest
|
class |
ApplyRequest
|
class |
GetAndAlterRequest
|
class |
GetRequest
|
class |
IsNullRequest
|
class |
ModifyRequest
|
class |
ReadRequest
|
Uses of ClientMessage in com.hazelcast.concurrent.countdownlatch.client |
---|
Subclasses of ClientMessage in com.hazelcast.concurrent.countdownlatch.client | |
---|---|
class |
AwaitRequest
|
class |
CountDownRequest
|
class |
GetCountRequest
|
class |
SetCountRequest
|
Uses of ClientMessage in com.hazelcast.concurrent.lock.client |
---|
Subclasses of ClientMessage in com.hazelcast.concurrent.lock.client | |
---|---|
class |
AbstractIsLockedRequest
|
class |
AbstractLockRequest
|
class |
AbstractUnlockRequest
|
class |
BeforeAwaitRequest
|
class |
GetLockCountRequest
|
class |
GetRemainingLeaseRequest
|
class |
IsLockedRequest
|
class |
LockRequest
|
class |
SignalRequest
|
class |
UnlockRequest
|
Uses of ClientMessage in com.hazelcast.concurrent.semaphore.client |
---|
Subclasses of ClientMessage in com.hazelcast.concurrent.semaphore.client | |
---|---|
class |
AcquireRequest
|
class |
AvailableRequest
|
class |
InitRequest
|
class |
ReduceRequest
|
class |
ReleaseRequest
|
class |
SemaphoreRequest
|
Uses of ClientMessage in com.hazelcast.executor.impl.client |
---|
Subclasses of ClientMessage in com.hazelcast.executor.impl.client | |
---|---|
class |
CancellationRequest
|
class |
IsShutdownRequest
|
class |
PartitionTargetCallableRequest
A TargetClientRequest which sends a Callable task
to a specific target. |
class |
ShutdownRequest
|
class |
SpecificTargetCallableRequest
A TargetClientRequest which sends
a Callable task to the given target address. |
Uses of ClientMessage in com.hazelcast.map.impl.client |
---|
Uses of ClientMessage in com.hazelcast.mapreduce.impl.client |
---|
Subclasses of ClientMessage in com.hazelcast.mapreduce.impl.client | |
---|---|
class |
ClientCancellationRequest
This class is used to request a map reduce job cancellation on the job owning node from the emitting client. |
class |
ClientJobProcessInformationRequest
This class is used to retrieve current processed records and other statistics from emitting client to the job owning node. |
class |
ClientMapReduceRequest<KeyIn,ValueIn>
This class is used to prepare and start a map reduce job emitted by a client on a random node in the cluster (making it the job owner). |
Uses of ClientMessage in com.hazelcast.multimap.impl.client |
---|
Uses of ClientMessage in com.hazelcast.nio |
---|
Methods in com.hazelcast.nio with parameters of type ClientMessage | |
---|---|
void |
NodeIOService.handleClientMessage(ClientMessage cm,
Connection connection)
|
void |
IOService.handleClientMessage(ClientMessage cm,
Connection connection)
|
Uses of ClientMessage in com.hazelcast.partition.client |
---|
Subclasses of ClientMessage in com.hazelcast.partition.client | |
---|---|
class |
AddPartitionLostListenerRequest
|
class |
GetPartitionsRequest
|
class |
RemovePartitionLostListenerRequest
|
Uses of ClientMessage in com.hazelcast.replicatedmap.impl.client |
---|
Uses of ClientMessage in com.hazelcast.topic.impl.client |
---|
Subclasses of ClientMessage in com.hazelcast.topic.impl.client | |
---|---|
class |
AddMessageListenerRequest
|
class |
PublishRequest
|
class |
RemoveMessageListenerRequest
|
Uses of ClientMessage in com.hazelcast.transaction.client |
---|
Subclasses of ClientMessage in com.hazelcast.transaction.client | |
---|---|
class |
BaseTransactionRequest
|
class |
BaseXATransactionRequest
|
class |
ClearRemoteTransactionRequest
|
class |
CollectXATransactionsRequest
|
class |
CommitTransactionRequest
|
class |
CommitXATransactionRequest
|
class |
CreateTransactionRequest
|
class |
CreateXATransactionRequest
|
class |
FinalizeXATransactionRequest
|
class |
PrepareXATransactionRequest
|
class |
RollbackTransactionRequest
|
class |
RollbackXATransactionRequest
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |