Modifier and Type | Method and Description |
---|---|
void |
ClientEngineImpl.accept(ClientMessage clientMessage) |
void |
NoOpClientEngine.accept(ClientMessage clientMessage) |
MessageTask |
CompositeMessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
protected V |
ClientDelegatingFuture.resolveResponse(ClientMessage clientMessage,
boolean deserialize) |
Modifier and Type | Method and Description |
---|---|
Throwable |
ClientExceptionFactory.createException(ClientMessage clientMessage) |
T |
ClientMessageDecoder.decodeClientMessage(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
void |
ClientConnection.handleClientMessage(ClientMessage message) |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ClientMessage.add(ClientMessage.Frame frame) |
ClientMessage |
ClientMessage.copyWithNewCorrelationId(long correlationId)
Copies the clientMessage efficiently with correlation id
Only initialFrame is duplicated, rest of the frames are shared
|
ClientMessage |
ClientExceptions.createExceptionMessage(Throwable throwable) |
static ClientMessage |
ClientMessage.createForDecode(ClientMessage.Frame startFrame) |
static ClientMessage |
ClientMessage.createForEncode() |
ClientMessage |
ClientMessageReader.getClientMessage() |
ClientMessage |
ClientMessage.setCorrelationId(long correlationId) |
ClientMessage |
ClientMessage.setMessageType(int messageType) |
ClientMessage |
ClientMessage.setNumberOfBackupAcks(int numberOfAcks)
Sets the setNumberOfAcks field.
|
ClientMessage |
ClientMessage.setPartitionId(int partitionId) |
Modifier and Type | Method and Description |
---|---|
MessageTask |
MessageTaskFactory.create(ClientMessage clientMessage,
Connection connection) |
void |
ClientMessage.merge(ClientMessage fragment) |
boolean |
ClientMessageWriter.writeTo(ByteBuffer dst,
ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ClientLocalBackupListenerCodec.encodeBackupEvent(long sourceInvocationCorrelationId) |
static ClientMessage |
CacheAddInvalidationListenerCodec.encodeCacheBatchInvalidationEvent(String name,
Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
CacheAddNearCacheInvalidationListenerCodec.encodeCacheBatchInvalidationEvent(String name,
Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
CacheAddEntryListenerCodec.encodeCacheEvent(int type,
Collection<CacheEventData> keys,
int completionId) |
static ClientMessage |
CacheAddInvalidationListenerCodec.encodeCacheInvalidationEvent(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
CacheAddNearCacheInvalidationListenerCodec.encodeCacheInvalidationEvent(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
CacheAddPartitionLostListenerCodec.encodeCachePartitionLostEvent(int partitionId,
UUID uuid) |
static ClientMessage |
ClientAddDistributedObjectListenerCodec.encodeDistributedObjectEvent(String name,
String serviceName,
String eventType) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerToKeyCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MultiMapAddEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddNearCacheEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerToKeyWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MultiMapAddEntryListenerToKeyCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddNearCacheEntryListenerCodec.encodeIMapBatchInvalidationEvent(Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
MapAddNearCacheInvalidationListenerCodec.encodeIMapBatchInvalidationEvent(Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
MapAddNearCacheEntryListenerCodec.encodeIMapInvalidationEvent(Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
MapAddNearCacheInvalidationListenerCodec.encodeIMapInvalidationEvent(Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
ListAddListenerCodec.encodeItemEvent(Data item,
UUID uuid,
int eventType) |
static ClientMessage |
QueueAddListenerCodec.encodeItemEvent(Data item,
UUID uuid,
int eventType) |
static ClientMessage |
SetAddListenerCodec.encodeItemEvent(Data item,
UUID uuid,
int eventType) |
static ClientMessage |
MapAddPartitionLostListenerCodec.encodeMapPartitionLostEvent(int partitionId,
UUID uuid) |
static ClientMessage |
ClientAddMembershipListenerCodec.encodeMemberAttributeChangeEvent(Member member,
Collection<Member> members,
String key,
int operationType,
String value) |
static ClientMessage |
ClientAddMembershipListenerCodec.encodeMemberEvent(Member member,
int eventType) |
static ClientMessage |
ClientAddMembershipListenerCodec.encodeMemberListEvent(Collection<Member> members) |
static ClientMessage |
ClientAddPartitionLostListenerCodec.encodePartitionLostEvent(int partitionId,
int lostBackupCount,
Address source) |
static ClientMessage |
ClientAddPartitionListenerCodec.encodePartitionsEvent(Collection<Map.Entry<Address,List<Integer>>> partitions,
int partitionStateVersion) |
static ClientMessage |
ContinuousQueryAddListenerCodec.encodeQueryCacheBatchEvent(Collection<QueryCacheEventData> events,
String source,
int partitionId) |
static ClientMessage |
ContinuousQueryAddListenerCodec.encodeQueryCacheSingleEvent(QueryCacheEventData data) |
static ClientMessage |
CacheAssignAndGetUuidsCodec.encodeRequest() |
static ClientMessage |
ClientRemoveAllListenersCodec.encodeRequest() |
static ClientMessage |
ClientAddPartitionListenerCodec.encodeRequest() |
static ClientMessage |
ClientPingCodec.encodeRequest() |
static ClientMessage |
ClientIsFailoverSupportedCodec.encodeRequest() |
static ClientMessage |
ClientGetDistributedObjectsCodec.encodeRequest() |
static ClientMessage |
XATransactionCollectTransactionsCodec.encodeRequest() |
static ClientMessage |
MapAssignAndGetUuidsCodec.encodeRequest() |
static ClientMessage |
ClientLocalBackupListenerCodec.encodeRequest() |
static ClientMessage |
ClientGetPartitionsCodec.encodeRequest() |
static ClientMessage |
ClientAddPartitionLostListenerCodec.encodeRequest(boolean localOnly) |
static ClientMessage |
ClientAddDistributedObjectListenerCodec.encodeRequest(boolean localOnly) |
static ClientMessage |
ClientAddMembershipListenerCodec.encodeRequest(boolean localOnly) |
static ClientMessage |
CacheCreateConfigCodec.encodeRequest(CacheConfigHolder cacheConfig,
boolean createAlsoOnOthers) |
static ClientMessage |
ClientDeployClassesCodec.encodeRequest(Collection<Map.Entry<String,byte[]>> classDefinitions) |
static ClientMessage |
ClientCreateProxiesCodec.encodeRequest(Collection<Map.Entry<String,String>> proxies) |
static ClientMessage |
CacheFetchNearCacheInvalidationMetadataCodec.encodeRequest(Collection<String> names,
Address address) |
static ClientMessage |
MapFetchNearCacheInvalidationMetadataCodec.encodeRequest(Collection<String> names,
Address address) |
static ClientMessage |
ClientAuthenticationCustomCodec.encodeRequest(Data credentials,
UUID uuid,
String clientType,
byte serializationVersion,
String clientHazelcastVersion,
String clientName,
Collection<String> labels,
int partitionCount,
UUID clusterId) |
static ClientMessage |
TransactionCreateCodec.encodeRequest(long timeout,
int durability,
int transactionType,
long threadId) |
static ClientMessage |
CPSessionGenerateThreadIdCodec.encodeRequest(RaftGroupId groupId) |
static ClientMessage |
CPSessionCloseSessionCodec.encodeRequest(RaftGroupId groupId,
long sessionId) |
static ClientMessage |
CPSessionHeartbeatSessionCodec.encodeRequest(RaftGroupId groupId,
long sessionId) |
static ClientMessage |
CountDownLatchGetCountCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
SemaphoreAvailablePermitsCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
CountDownLatchGetRoundCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
FencedLockGetLockOwnershipCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
AtomicRefGetCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
CPSessionCreateSessionCodec.encodeRequest(RaftGroupId groupId,
String endpointName) |
static ClientMessage |
AtomicLongGetCodec.encodeRequest(RaftGroupId groupId,
String name) |
static ClientMessage |
AtomicRefContainsCodec.encodeRequest(RaftGroupId groupId,
String name,
Data value) |
static ClientMessage |
AtomicLongApplyCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function) |
static ClientMessage |
AtomicRefSetCodec.encodeRequest(RaftGroupId groupId,
String name,
Data newValue,
boolean returnOldValue) |
static ClientMessage |
AtomicRefCompareAndSetCodec.encodeRequest(RaftGroupId groupId,
String name,
Data oldValue,
Data newValue) |
static ClientMessage |
AtomicLongAlterCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function,
int returnValueType) |
static ClientMessage |
AtomicRefApplyCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function,
int returnValueType,
boolean alter) |
static ClientMessage |
SemaphoreInitCodec.encodeRequest(RaftGroupId groupId,
String name,
int permits) |
static ClientMessage |
CountDownLatchTrySetCountCodec.encodeRequest(RaftGroupId groupId,
String name,
int count) |
static ClientMessage |
AtomicLongGetAndSetCodec.encodeRequest(RaftGroupId groupId,
String name,
long newValue) |
static ClientMessage |
AtomicLongAddAndGetCodec.encodeRequest(RaftGroupId groupId,
String name,
long delta) |
static ClientMessage |
AtomicLongGetAndAddCodec.encodeRequest(RaftGroupId groupId,
String name,
long delta) |
static ClientMessage |
AtomicLongCompareAndSetCodec.encodeRequest(RaftGroupId groupId,
String name,
long expected,
long updated) |
static ClientMessage |
FencedLockLockCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid) |
static ClientMessage |
FencedLockUnlockCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid) |
static ClientMessage |
SemaphoreDrainCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid) |
static ClientMessage |
SemaphoreChangeCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
int permits) |
static ClientMessage |
SemaphoreReleaseCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
int permits) |
static ClientMessage |
SemaphoreAcquireCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
int permits,
long timeoutMs) |
static ClientMessage |
FencedLockTryLockCodec.encodeRequest(RaftGroupId groupId,
String name,
long sessionId,
long threadId,
UUID invocationUid,
long timeoutMs) |
static ClientMessage |
CPGroupDestroyCPObjectCodec.encodeRequest(RaftGroupId groupId,
String serviceName,
String objectName) |
static ClientMessage |
CountDownLatchCountDownCodec.encodeRequest(RaftGroupId groupId,
String name,
UUID invocationUid,
int expectedRound) |
static ClientMessage |
CountDownLatchAwaitCodec.encodeRequest(RaftGroupId groupId,
String name,
UUID invocationUid,
long timeoutMs) |
static ClientMessage |
QueueIsEmptyCodec.encodeRequest(String name) |
static ClientMessage |
MapFlushCodec.encodeRequest(String name) |
static ClientMessage |
ListSizeCodec.encodeRequest(String name) |
static ClientMessage |
MapIsEmptyCodec.encodeRequest(String name) |
static ClientMessage |
ReplicatedMapClearCodec.encodeRequest(String name) |
static ClientMessage |
MultiMapClearCodec.encodeRequest(String name) |
static ClientMessage |
MapSizeCodec.encodeRequest(String name) |
static ClientMessage |
SetSizeCodec.encodeRequest(String name) |
static ClientMessage |
CacheEventJournalSubscribeCodec.encodeRequest(String name) |
static ClientMessage |
SetClearCodec.encodeRequest(String name) |
static ClientMessage |
ListClearCodec.encodeRequest(String name) |
static ClientMessage |
DurableExecutorIsShutdownCodec.encodeRequest(String name) |
static ClientMessage |
ScheduledExecutorGetAllScheduledFuturesCodec.encodeRequest(String schedulerName) |
static ClientMessage |
QueueTakeCodec.encodeRequest(String name) |
static ClientMessage |
CacheDestroyCodec.encodeRequest(String name) |
static ClientMessage |
ListIsEmptyCodec.encodeRequest(String name) |
static ClientMessage |
SetGetAllCodec.encodeRequest(String name) |
static ClientMessage |
CacheClearCodec.encodeRequest(String name) |
static ClientMessage |
SetIsEmptyCodec.encodeRequest(String name) |
static ClientMessage |
CacheSizeCodec.encodeRequest(String name) |
static ClientMessage |
MultiMapSizeCodec.encodeRequest(String name) |
static ClientMessage |
CPGroupCreateCPGroupCodec.encodeRequest(String proxyName) |
static ClientMessage |
RingbufferSizeCodec.encodeRequest(String name) |
static ClientMessage |
MapEvictAllCodec.encodeRequest(String name) |
static ClientMessage |
QueueClearCodec.encodeRequest(String name) |
static ClientMessage |
MultiMapEntrySetCodec.encodeRequest(String name) |
static ClientMessage |
ClientStatisticsCodec.encodeRequest(String stats) |
static ClientMessage |
MultiMapValuesCodec.encodeRequest(String name) |
static ClientMessage |
ExecutorServiceIsShutdownCodec.encodeRequest(String name) |
static ClientMessage |
QueueIteratorCodec.encodeRequest(String name) |
static ClientMessage |
RingbufferRemainingCapacityCodec.encodeRequest(String name) |
static ClientMessage |
MapKeySetCodec.encodeRequest(String name) |
static ClientMessage |
DurableExecutorShutdownCodec.encodeRequest(String name) |
static ClientMessage |
MapClearCodec.encodeRequest(String name) |
static ClientMessage |
MapEntrySetCodec.encodeRequest(String name) |
static ClientMessage |
RingbufferCapacityCodec.encodeRequest(String name) |
static ClientMessage |
MapValuesCodec.encodeRequest(String name) |
static ClientMessage |
QueueDrainToCodec.encodeRequest(String name) |
static ClientMessage |
RingbufferHeadSequenceCodec.encodeRequest(String name) |
static ClientMessage |
ExecutorServiceShutdownCodec.encodeRequest(String name) |
static ClientMessage |
QueueSizeCodec.encodeRequest(String name) |
static ClientMessage |
RingbufferTailSequenceCodec.encodeRequest(String name) |
static ClientMessage |
ListIteratorCodec.encodeRequest(String name) |
static ClientMessage |
PNCounterGetConfiguredReplicaCountCodec.encodeRequest(String name) |
static ClientMessage |
QueuePeekCodec.encodeRequest(String name) |
static ClientMessage |
ReplicatedMapIsEmptyCodec.encodeRequest(String name) |
static ClientMessage |
SemaphoreGetSemaphoreTypeCodec.encodeRequest(String proxyName) |
static ClientMessage |
MapEventJournalSubscribeCodec.encodeRequest(String name) |
static ClientMessage |
ReplicatedMapSizeCodec.encodeRequest(String name) |
static ClientMessage |
CardinalityEstimatorEstimateCodec.encodeRequest(String name) |
static ClientMessage |
ReplicatedMapKeySetCodec.encodeRequest(String name) |
static ClientMessage |
ListGetAllCodec.encodeRequest(String name) |
static ClientMessage |
ReplicatedMapValuesCodec.encodeRequest(String name) |
static ClientMessage |
QueueRemainingCapacityCodec.encodeRequest(String name) |
static ClientMessage |
ReplicatedMapEntrySetCodec.encodeRequest(String name) |
static ClientMessage |
MultiMapKeySetCodec.encodeRequest(String name) |
static ClientMessage |
MapClearNearCacheCodec.encodeRequest(String name,
Address target) |
static ClientMessage |
ScheduledExecutorShutdownCodec.encodeRequest(String schedulerName,
Address address) |
static ClientMessage |
ScheduledExecutorSubmitToAddressCodec.encodeRequest(String schedulerName,
Address address,
byte type,
String taskName,
Data task,
long initialDelayInMillis,
long periodInMillis) |
static ClientMessage |
MapLoadAllCodec.encodeRequest(String name,
boolean replaceExistingValues) |
static ClientMessage |
TopicAddMessageListenerCodec.encodeRequest(String name,
boolean localOnly) |
static ClientMessage |
CacheAddEntryListenerCodec.encodeRequest(String name,
boolean localOnly) |
static ClientMessage |
CacheAddInvalidationListenerCodec.encodeRequest(String name,
boolean localOnly) |
static ClientMessage |
CacheAddNearCacheInvalidationListenerCodec.encodeRequest(String name,
boolean localOnly) |
static ClientMessage |
ContinuousQueryAddListenerCodec.encodeRequest(String listenerName,
boolean localOnly) |
static ClientMessage |
CacheAddPartitionLostListenerCodec.encodeRequest(String name,
boolean localOnly) |
static ClientMessage |
MapAddPartitionLostListenerCodec.encodeRequest(String name,
boolean localOnly) |
static ClientMessage |
ReplicatedMapAddEntryListenerCodec.encodeRequest(String name,
boolean localOnly) |
static ClientMessage |
MultiMapAddEntryListenerCodec.encodeRequest(String name,
boolean includeValue,
boolean localOnly) |
static ClientMessage |
ListAddListenerCodec.encodeRequest(String name,
boolean includeValue,
boolean localOnly) |
static ClientMessage |
ReplicatedMapAddNearCacheEntryListenerCodec.encodeRequest(String name,
boolean includeValue,
boolean localOnly) |
static ClientMessage |
QueueAddListenerCodec.encodeRequest(String name,
boolean includeValue,
boolean localOnly) |
static ClientMessage |
SetAddListenerCodec.encodeRequest(String name,
boolean includeValue,
boolean localOnly) |
static ClientMessage |
CacheManagementConfigCodec.encodeRequest(String name,
boolean isStat,
boolean enabled,
Address address) |
static ClientMessage |
DynamicConfigAddTopicConfigCodec.encodeRequest(String name,
boolean globalOrderingEnabled,
boolean statisticsEnabled,
boolean multiThreadingEnabled,
Collection<ListenerConfigHolder> listenerConfigs) |
static ClientMessage |
MapAddEntryListenerCodec.encodeRequest(String name,
boolean includeValue,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
ScheduledExecutorSubmitToPartitionCodec.encodeRequest(String schedulerName,
byte type,
String taskName,
Data task,
long initialDelayInMillis,
long periodInMillis) |
static ClientMessage |
QueueCompareAndRetainAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
QueueCompareAndRemoveAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
ListAddAllCodec.encodeRequest(String name,
Collection<Data> valueList) |
static ClientMessage |
QueueContainsAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
SetContainsAllCodec.encodeRequest(String name,
Collection<Data> items) |
static ClientMessage |
ListContainsAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
SetCompareAndRemoveAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
SetCompareAndRetainAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
MapGetAllCodec.encodeRequest(String name,
Collection<Data> keys) |
static ClientMessage |
ListCompareAndRemoveAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
SetAddAllCodec.encodeRequest(String name,
Collection<Data> valueList) |
static ClientMessage |
QueueAddAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
ListCompareAndRetainAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
MapLoadGivenKeysCodec.encodeRequest(String name,
Collection<Data> keys,
boolean replaceExistingValues) |
static ClientMessage |
CacheLoadAllCodec.encodeRequest(String name,
Collection<Data> keys,
boolean replaceExistingValues) |
static ClientMessage |
CacheGetAllCodec.encodeRequest(String name,
Collection<Data> keys,
Data expiryPolicy) |
static ClientMessage |
CacheSetExpiryPolicyCodec.encodeRequest(String name,
Collection<Data> keys,
Data expiryPolicy) |
static ClientMessage |
RingbufferAddAllCodec.encodeRequest(String name,
Collection<Data> valueList,
int overflowPolicy) |
static ClientMessage |
CacheRemoveAllKeysCodec.encodeRequest(String name,
Collection<Data> keys,
int completionId) |
static ClientMessage |
DynamicConfigAddReliableTopicConfigCodec.encodeRequest(String name,
Collection<ListenerConfigHolder> listenerConfigs,
int readBatchSize,
boolean statisticsEnabled,
String topicOverloadPolicy,
Data executor) |
static ClientMessage |
DynamicConfigAddSetConfigCodec.encodeRequest(String name,
Collection<ListenerConfigHolder> listenerConfigs,
int backupCount,
int asyncBackupCount,
int maxSize,
boolean statisticsEnabled,
String splitBrainProtectionName,
String mergePolicy,
int mergeBatchSize) |
static ClientMessage |
DynamicConfigAddListConfigCodec.encodeRequest(String name,
Collection<ListenerConfigHolder> listenerConfigs,
int backupCount,
int asyncBackupCount,
int maxSize,
boolean statisticsEnabled,
String splitBrainProtectionName,
String mergePolicy,
int mergeBatchSize) |
static ClientMessage |
DynamicConfigAddQueueConfigCodec.encodeRequest(String name,
Collection<ListenerConfigHolder> listenerConfigs,
int backupCount,
int asyncBackupCount,
int maxSize,
int emptyQueueTtl,
boolean statisticsEnabled,
String splitBrainProtectionName,
QueueStoreConfigHolder queueStoreConfig,
String mergePolicy,
int mergeBatchSize) |
static ClientMessage |
MapPutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
ReplicatedMapPutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
CachePutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries,
Data expiryPolicy,
int completionId) |
static ClientMessage |
PNCounterGetCodec.encodeRequest(String name,
Collection<Map.Entry<UUID,Long>> replicaTimestamps,
Address targetReplica) |
static ClientMessage |
MapEntriesWithPagingPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
MapAggregateCodec.encodeRequest(String name,
Data aggregator) |
static ClientMessage |
QueueContainsCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapValuesWithPagingPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
ListLastIndexOfCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapContainsValueCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapProjectCodec.encodeRequest(String name,
Data projection) |
static ClientMessage |
MapAddInterceptorCodec.encodeRequest(String name,
Data interceptor) |
static ClientMessage |
TopicPublishCodec.encodeRequest(String name,
Data message) |
static ClientMessage |
ReplicatedMapRemoveCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MultiMapContainsValueCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ReplicatedMapContainsKeyCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
SetAddCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapValuesWithPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
QueueRemoveCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ListAddCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
QueuePutCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ReplicatedMapContainsValueCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ListContainsCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
CacheContainsKeyCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MapKeySetWithPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
MapRemoveAllCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
ReplicatedMapGetCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MapEntriesWithPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
DurableExecutorSubmitToPartitionCodec.encodeRequest(String name,
Data callable) |
static ClientMessage |
MapExecuteOnAllKeysCodec.encodeRequest(String name,
Data entryProcessor) |
static ClientMessage |
SetRemoveCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ListIndexOfCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapKeySetWithPagingPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
ListRemoveCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapIsLockedCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MultiMapIsLockedCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
SetContainsCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateCodec.encodeRequest(String name,
Data predicate,
boolean localOnly) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyCodec.encodeRequest(String name,
Data key,
boolean localOnly) |
static ClientMessage |
CacheListenerRegistrationCodec.encodeRequest(String name,
Data listenerConfig,
boolean shouldRegister,
Address address) |
static ClientMessage |
MultiMapAddEntryListenerToKeyCodec.encodeRequest(String name,
Data key,
boolean includeValue,
boolean localOnly) |
static ClientMessage |
MapAddEntryListenerToKeyCodec.encodeRequest(String name,
Data key,
boolean includeValue,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
MapAddEntryListenerWithPredicateCodec.encodeRequest(String name,
Data predicate,
boolean includeValue,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
MapExecuteOnKeysCodec.encodeRequest(String name,
Data entryProcessor,
Collection<Data> keys) |
static ClientMessage |
MapExecuteWithPredicateCodec.encodeRequest(String name,
Data entryProcessor,
Data predicate) |
static ClientMessage |
MapAggregateWithPredicateCodec.encodeRequest(String name,
Data aggregator,
Data predicate) |
static ClientMessage |
CacheGetCodec.encodeRequest(String name,
Data key,
Data expiryPolicy) |
static ClientMessage |
MapProjectWithPredicateCodec.encodeRequest(String name,
Data projection,
Data predicate) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.encodeRequest(String name,
Data key,
Data predicate,
boolean localOnly) |
static ClientMessage |
MapAddEntryListenerToKeyWithPredicateCodec.encodeRequest(String name,
Data key,
Data predicate,
boolean includeValue,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
CacheEntryProcessorCodec.encodeRequest(String name,
Data key,
Data entryProcessor,
Collection<Data> arguments,
int completionId) |
static ClientMessage |
CachePutCodec.encodeRequest(String name,
Data key,
Data value,
Data expiryPolicy,
boolean get,
int completionId) |
static ClientMessage |
CacheReplaceCodec.encodeRequest(String name,
Data key,
Data oldValue,
Data newValue,
Data expiryPolicy,
int completionId) |
static ClientMessage |
CacheGetAndReplaceCodec.encodeRequest(String name,
Data key,
Data value,
Data expiryPolicy,
int completionId) |
static ClientMessage |
CachePutIfAbsentCodec.encodeRequest(String name,
Data key,
Data value,
Data expiryPolicy,
int completionId) |
static ClientMessage |
MapReplaceIfSameCodec.encodeRequest(String name,
Data key,
Data testValue,
Data value,
long threadId) |
static ClientMessage |
CacheRemoveCodec.encodeRequest(String name,
Data key,
Data currentValue,
int completionId) |
static ClientMessage |
MultiMapContainsEntryCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
ReplicatedMapPutCodec.encodeRequest(String name,
Data key,
Data value,
long ttl) |
static ClientMessage |
MapSubmitToKeyCodec.encodeRequest(String name,
Data entryProcessor,
Data key,
long threadId) |
static ClientMessage |
MultiMapPutCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MultiMapRemoveEntryCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MapRemoveIfSameCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MapExecuteOnKeyCodec.encodeRequest(String name,
Data entryProcessor,
Data key,
long threadId) |
static ClientMessage |
MapReplaceCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MapPutTransientCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapTryPutCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long timeout) |
static ClientMessage |
MapSetCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapPutCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapPutIfAbsentCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapSetWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
MapPutTransientWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
MapPutIfAbsentWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
MapPutWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
CacheGetAndRemoveCodec.encodeRequest(String name,
Data key,
int completionId) |
static ClientMessage |
MapForceUnlockCodec.encodeRequest(String name,
Data key,
long referenceId) |
static ClientMessage |
MultiMapForceUnlockCodec.encodeRequest(String name,
Data key,
long referenceId) |
static ClientMessage |
MapGetEntryViewCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapRemoveCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapGetCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapDeleteCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapEvictCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
QueueOfferCodec.encodeRequest(String name,
Data value,
long timeoutMillis) |
static ClientMessage |
MapContainsKeyCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapSetTtlCodec.encodeRequest(String name,
Data key,
long ttl) |
static ClientMessage |
MultiMapRemoveCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapContainsKeyCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapGetCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapValueCountCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapDeleteCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapUnlockCodec.encodeRequest(String name,
Data key,
long threadId,
long referenceId) |
static ClientMessage |
MapTryRemoveCodec.encodeRequest(String name,
Data key,
long threadId,
long timeout) |
static ClientMessage |
MapUnlockCodec.encodeRequest(String name,
Data key,
long threadId,
long referenceId) |
static ClientMessage |
MapLockCodec.encodeRequest(String name,
Data key,
long threadId,
long ttl,
long referenceId) |
static ClientMessage |
MultiMapLockCodec.encodeRequest(String name,
Data key,
long threadId,
long ttl,
long referenceId) |
static ClientMessage |
MultiMapTryLockCodec.encodeRequest(String name,
Data key,
long threadId,
long lease,
long timeout,
long referenceId) |
static ClientMessage |
MapTryLockCodec.encodeRequest(String name,
Data key,
long threadId,
long lease,
long timeout,
long referenceId) |
static ClientMessage |
MapAddIndexCodec.encodeRequest(String name,
IndexConfig indexConfig) |
static ClientMessage |
ListGetCodec.encodeRequest(String name,
int index) |
static ClientMessage |
QueueDrainToMaxSizeCodec.encodeRequest(String name,
int maxSize) |
static ClientMessage |
DurableExecutorRetrieveResultCodec.encodeRequest(String name,
int sequence) |
static ClientMessage |
FlakeIdGeneratorNewIdBatchCodec.encodeRequest(String name,
int batchSize) |
static ClientMessage |
ListListIteratorCodec.encodeRequest(String name,
int index) |
static ClientMessage |
ListRemoveWithIndexCodec.encodeRequest(String name,
int index) |
static ClientMessage |
CacheRemoveAllCodec.encodeRequest(String name,
int completionId) |
static ClientMessage |
DurableExecutorDisposeResultCodec.encodeRequest(String name,
int sequence) |
static ClientMessage |
DurableExecutorRetrieveAndDisposeResultCodec.encodeRequest(String name,
int sequence) |
static ClientMessage |
MapAddNearCacheEntryListenerCodec.encodeRequest(String name,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
MapAddNearCacheInvalidationListenerCodec.encodeRequest(String name,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
DynamicConfigAddPNCounterConfigCodec.encodeRequest(String name,
int replicaCount,
boolean statisticsEnabled,
String splitBrainProtectionName) |
static ClientMessage |
ListAddAllWithIndexCodec.encodeRequest(String name,
int index,
Collection<Data> valueList) |
static ClientMessage |
ListAddWithIndexCodec.encodeRequest(String name,
int index,
Data value) |
static ClientMessage |
RingbufferAddCodec.encodeRequest(String name,
int overflowPolicy,
Data value) |
static ClientMessage |
ListSetCodec.encodeRequest(String name,
int index,
Data value) |
static ClientMessage |
CacheIterateCodec.encodeRequest(String name,
int tableIndex,
int batch) |
static ClientMessage |
ListSubCodec.encodeRequest(String name,
int from,
int to) |
static ClientMessage |
CacheIterateEntriesCodec.encodeRequest(String name,
int tableIndex,
int batch) |
static ClientMessage |
MapFetchKeysCodec.encodeRequest(String name,
int tableIndex,
int batch) |
static ClientMessage |
MapFetchEntriesCodec.encodeRequest(String name,
int tableIndex,
int batch) |
static ClientMessage |
DynamicConfigAddExecutorConfigCodec.encodeRequest(String name,
int poolSize,
int queueCapacity,
boolean statisticsEnabled,
String splitBrainProtectionName) |
static ClientMessage |
MapFetchWithQueryCodec.encodeRequest(String name,
int tableIndex,
int batch,
Data projection,
Data predicate) |
static ClientMessage |
DynamicConfigAddMapConfigCodec.encodeRequest(String name,
int backupCount,
int asyncBackupCount,
int timeToLiveSeconds,
int maxIdleSeconds,
String evictionPolicy,
boolean readBackupData,
String cacheDeserializedValues,
String mergePolicy,
String inMemoryFormat,
Collection<ListenerConfigHolder> listenerConfigs,
Collection<ListenerConfigHolder> partitionLostListenerConfigs,
boolean statisticsEnabled,
String splitBrainProtectionName,
Data mapEvictionPolicy,
String maxSizeConfigMaxSizePolicy,
int maxSizeConfigSize,
MapStoreConfigHolder mapStoreConfig,
NearCacheConfigHolder nearCacheConfig,
WanReplicationRef wanReplicationRef,
Collection<IndexConfig> indexConfigs,
Collection<AttributeConfig> attributeConfigs,
Collection<QueryCacheConfigHolder> queryCacheConfigs,
String partitioningStrategyClassName,
Data partitioningStrategyImplementation,
HotRestartConfig hotRestartConfig,
EventJournalConfig eventJournalConfig,
MerkleTreeConfig merkleTreeConfig,
int mergeBatchSize,
int metadataPolicy) |
static ClientMessage |
DynamicConfigAddRingbufferConfigCodec.encodeRequest(String name,
int capacity,
int backupCount,
int asyncBackupCount,
int timeToLiveSeconds,
String inMemoryFormat,
RingbufferStoreConfigHolder ringbufferStoreConfig,
String splitBrainProtectionName,
String mergePolicy,
int mergeBatchSize) |
static ClientMessage |
DynamicConfigAddDurableExecutorConfigCodec.encodeRequest(String name,
int poolSize,
int durability,
int capacity,
String splitBrainProtectionName) |
static ClientMessage |
DynamicConfigAddScheduledExecutorConfigCodec.encodeRequest(String name,
int poolSize,
int durability,
int capacity,
String splitBrainProtectionName,
String mergePolicy,
int mergeBatchSize) |
static ClientMessage |
DynamicConfigAddCardinalityEstimatorConfigCodec.encodeRequest(String name,
int backupCount,
int asyncBackupCount,
String splitBrainProtectionName,
String mergePolicy,
int mergeBatchSize) |
static ClientMessage |
DynamicConfigAddFlakeIdGeneratorConfigCodec.encodeRequest(String name,
int prefetchCount,
long prefetchValidity,
long idOffset,
boolean statisticsEnabled,
long nodeIdOffset) |
static ClientMessage |
QueuePollCodec.encodeRequest(String name,
long timeoutMillis) |
static ClientMessage |
RingbufferReadOneCodec.encodeRequest(String name,
long sequence) |
static ClientMessage |
CardinalityEstimatorAddCodec.encodeRequest(String name,
long hash) |
static ClientMessage |
PNCounterAddCodec.encodeRequest(String name,
long delta,
boolean getBeforeUpdate,
Collection<Map.Entry<UUID,Long>> replicaTimestamps,
Address targetReplica) |
static ClientMessage |
RingbufferReadManyCodec.encodeRequest(String name,
long startSequence,
int minCount,
int maxCount,
Data filter) |
static ClientMessage |
CacheEventJournalReadCodec.encodeRequest(String name,
long startSequence,
int minSize,
int maxSize,
Data predicate,
Data projection) |
static ClientMessage |
MapEventJournalReadCodec.encodeRequest(String name,
long startSequence,
int minSize,
int maxSize,
Data predicate,
Data projection) |
static ClientMessage |
ContinuousQueryMadePublishableCodec.encodeRequest(String mapName,
String cacheName) |
static ClientMessage |
ScheduledExecutorGetStatsFromPartitionCodec.encodeRequest(String schedulerName,
String taskName) |
static ClientMessage |
ScheduledExecutorGetDelayFromPartitionCodec.encodeRequest(String schedulerName,
String taskName) |
static ClientMessage |
ContinuousQueryDestroyCacheCodec.encodeRequest(String mapName,
String cacheName) |
static ClientMessage |
ScheduledExecutorGetResultFromPartitionCodec.encodeRequest(String schedulerName,
String taskName) |
static ClientMessage |
ClientDestroyProxyCodec.encodeRequest(String name,
String serviceName) |
static ClientMessage |
ScheduledExecutorIsCancelledFromPartitionCodec.encodeRequest(String schedulerName,
String taskName) |
static ClientMessage |
CacheGetConfigCodec.encodeRequest(String name,
String simpleName) |
static ClientMessage |
ScheduledExecutorDisposeFromPartitionCodec.encodeRequest(String schedulerName,
String taskName) |
static ClientMessage |
ScheduledExecutorIsDoneFromPartitionCodec.encodeRequest(String schedulerName,
String taskName) |
static ClientMessage |
MapRemoveInterceptorCodec.encodeRequest(String name,
String id) |
static ClientMessage |
ScheduledExecutorIsDoneFromAddressCodec.encodeRequest(String schedulerName,
String taskName,
Address address) |
static ClientMessage |
ScheduledExecutorGetDelayFromAddressCodec.encodeRequest(String schedulerName,
String taskName,
Address address) |
static ClientMessage |
ScheduledExecutorGetResultFromAddressCodec.encodeRequest(String schedulerName,
String taskName,
Address address) |
static ClientMessage |
ScheduledExecutorGetStatsFromAddressCodec.encodeRequest(String schedulerName,
String taskName,
Address address) |
static ClientMessage |
ScheduledExecutorDisposeFromAddressCodec.encodeRequest(String schedulerName,
String taskName,
Address address) |
static ClientMessage |
ScheduledExecutorIsCancelledFromAddressCodec.encodeRequest(String schedulerName,
String taskName,
Address address) |
static ClientMessage |
ClientCreateProxyCodec.encodeRequest(String name,
String serviceName,
Address target) |
static ClientMessage |
ScheduledExecutorCancelFromAddressCodec.encodeRequest(String schedulerName,
String taskName,
Address address,
boolean mayInterruptIfRunning) |
static ClientMessage |
ScheduledExecutorCancelFromPartitionCodec.encodeRequest(String schedulerName,
String taskName,
boolean mayInterruptIfRunning) |
static ClientMessage |
DynamicConfigAddReplicatedMapConfigCodec.encodeRequest(String name,
String inMemoryFormat,
boolean asyncFillup,
boolean statisticsEnabled,
String mergePolicy,
Collection<ListenerConfigHolder> listenerConfigs,
String splitBrainProtectionName,
int mergeBatchSize) |
static ClientMessage |
DynamicConfigAddMultiMapConfigCodec.encodeRequest(String name,
String collectionType,
Collection<ListenerConfigHolder> listenerConfigs,
boolean binary,
int backupCount,
int asyncBackupCount,
boolean statisticsEnabled,
String splitBrainProtectionName,
String mergePolicy,
int mergeBatchSize) |
static ClientMessage |
ContinuousQueryPublisherCreateCodec.encodeRequest(String mapName,
String cacheName,
Data predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean populate,
boolean coalesce) |
static ClientMessage |
ContinuousQueryPublisherCreateWithValueCodec.encodeRequest(String mapName,
String cacheName,
Data predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean populate,
boolean coalesce) |
static ClientMessage |
ContinuousQuerySetReadCursorCodec.encodeRequest(String mapName,
String cacheName,
long sequence) |
static ClientMessage |
DynamicConfigAddCacheConfigCodec.encodeRequest(String name,
String keyType,
String valueType,
boolean statisticsEnabled,
boolean managementEnabled,
boolean readThrough,
boolean writeThrough,
String cacheLoaderFactory,
String cacheWriterFactory,
String cacheLoader,
String cacheWriter,
int backupCount,
int asyncBackupCount,
String inMemoryFormat,
String splitBrainProtectionName,
String mergePolicy,
boolean disablePerEntryInvalidationEvents,
Collection<ListenerConfigHolder> partitionLostListenerConfigs,
String expiryPolicyFactoryClassName,
CacheSimpleConfig.ExpiryPolicyFactoryConfig.TimedExpiryPolicyFactoryConfig timedExpiryPolicyFactoryConfig,
Collection<CacheSimpleEntryListenerConfig> cacheEntryListeners,
EvictionConfigHolder evictionConfig,
WanReplicationRef wanReplicationRef,
EventJournalConfig eventJournalConfig,
HotRestartConfig hotRestartConfig) |
static ClientMessage |
ClientAuthenticationCodec.encodeRequest(String username,
String password,
UUID uuid,
String clientType,
byte serializationVersion,
String clientHazelcastVersion,
String clientName,
Collection<String> labels,
int partitionCount,
UUID clusterId) |
static ClientMessage |
MapRemovePartitionLostListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
ReplicatedMapRemoveEntryListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
ListRemoveListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
CacheRemoveInvalidationListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
TopicRemoveMessageListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
MultiMapRemoveEntryListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
MapRemoveEntryListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
SetRemoveListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
QueueRemoveListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
CacheRemoveEntryListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
CacheRemovePartitionLostListenerCodec.encodeRequest(String name,
UUID registrationId) |
static ClientMessage |
ExecutorServiceSubmitToPartitionCodec.encodeRequest(String name,
UUID uuid,
Data callable) |
static ClientMessage |
ExecutorServiceSubmitToAddressCodec.encodeRequest(String name,
UUID uuid,
Data callable,
Address address) |
static ClientMessage |
TransactionalMapSizeCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalMapIsEmptyCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalQueueTakeCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalListSizeCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalMultiMapSizeCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalMapKeySetCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalSetSizeCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalMapValuesCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalQueueSizeCodec.encodeRequest(String name,
UUID txnId,
long threadId) |
static ClientMessage |
TransactionalMapContainsValueCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data value) |
static ClientMessage |
TransactionalMultiMapGetCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMultiMapRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapGetForUpdateCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapContainsKeyCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapKeySetWithPredicateCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data predicate) |
static ClientMessage |
TransactionalMapDeleteCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalSetRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalListAddCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalSetAddCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalMapValuesWithPredicateCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data predicate) |
static ClientMessage |
TransactionalListRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalMapGetCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMultiMapValueCountCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapReplaceCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapRemoveIfSameCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMultiMapRemoveEntryCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapPutIfAbsentCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapSetCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMultiMapPutCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapReplaceIfSameCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data oldValue,
Data newValue) |
static ClientMessage |
TransactionalMapPutCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value,
long ttl) |
static ClientMessage |
TransactionalQueueOfferCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item,
long timeout) |
static ClientMessage |
TransactionalQueuePollCodec.encodeRequest(String name,
UUID txnId,
long threadId,
long timeout) |
static ClientMessage |
TransactionalQueuePeekCodec.encodeRequest(String name,
UUID txnId,
long threadId,
long timeout) |
static ClientMessage |
XATransactionPrepareCodec.encodeRequest(UUID transactionId) |
static ClientMessage |
XATransactionRollbackCodec.encodeRequest(UUID transactionId) |
static ClientMessage |
ClientRemoveDistributedObjectListenerCodec.encodeRequest(UUID registrationId) |
static ClientMessage |
ClientRemovePartitionLostListenerCodec.encodeRequest(UUID registrationId) |
static ClientMessage |
ExecutorServiceCancelOnAddressCodec.encodeRequest(UUID uuid,
Address address,
boolean interrupt) |
static ClientMessage |
ExecutorServiceCancelOnPartitionCodec.encodeRequest(UUID uuid,
boolean interrupt) |
static ClientMessage |
XATransactionCommitCodec.encodeRequest(UUID transactionId,
boolean onePhase) |
static ClientMessage |
MetricsReadMetricsCodec.encodeRequest(UUID uuid,
long fromSequence) |
static ClientMessage |
TransactionRollbackCodec.encodeRequest(UUID transactionId,
long threadId) |
static ClientMessage |
TransactionCommitCodec.encodeRequest(UUID transactionId,
long threadId) |
static ClientMessage |
XATransactionClearRemoteCodec.encodeRequest(Xid xid) |
static ClientMessage |
XATransactionFinalizeCodec.encodeRequest(Xid xid,
boolean isCommit) |
static ClientMessage |
XATransactionCreateCodec.encodeRequest(Xid xid,
long timeout) |
static ClientMessage |
ClientRemoveAllListenersCodec.encodeResponse() |
static ClientMessage |
MapFlushCodec.encodeResponse() |
static ClientMessage |
CPGroupDestroyCPObjectCodec.encodeResponse() |
static ClientMessage |
CountDownLatchCountDownCodec.encodeResponse() |
static ClientMessage |
ListAddWithIndexCodec.encodeResponse() |
static ClientMessage |
MapForceUnlockCodec.encodeResponse() |
static ClientMessage |
MapLoadAllCodec.encodeResponse() |
static ClientMessage |
ClientAddPartitionListenerCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddTopicConfigCodec.encodeResponse() |
static ClientMessage |
MultiMapUnlockCodec.encodeResponse() |
static ClientMessage |
ClientPingCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddPNCounterConfigCodec.encodeResponse() |
static ClientMessage |
ReplicatedMapClearCodec.encodeResponse() |
static ClientMessage |
MultiMapClearCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddReliableTopicConfigCodec.encodeResponse() |
static ClientMessage |
MultiMapForceUnlockCodec.encodeResponse() |
static ClientMessage |
TopicPublishCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddMultiMapConfigCodec.encodeResponse() |
static ClientMessage |
SetClearCodec.encodeResponse() |
static ClientMessage |
ListClearCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddSetConfigCodec.encodeResponse() |
static ClientMessage |
MapLockCodec.encodeResponse() |
static ClientMessage |
CacheDestroyCodec.encodeResponse() |
static ClientMessage |
CacheListenerRegistrationCodec.encodeResponse() |
static ClientMessage |
MapPutTransientCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddRingbufferConfigCodec.encodeResponse() |
static ClientMessage |
XATransactionPrepareCodec.encodeResponse() |
static ClientMessage |
MultiMapDeleteCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddScheduledExecutorConfigCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddDurableExecutorConfigCodec.encodeResponse() |
static ClientMessage |
TransactionalMapDeleteCodec.encodeResponse() |
static ClientMessage |
ScheduledExecutorSubmitToAddressCodec.encodeResponse() |
static ClientMessage |
XATransactionFinalizeCodec.encodeResponse() |
static ClientMessage |
CacheClearCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddFlakeIdGeneratorConfigCodec.encodeResponse() |
static ClientMessage |
QueuePutCodec.encodeResponse() |
static ClientMessage |
ClientDestroyProxyCodec.encodeResponse() |
static ClientMessage |
XATransactionClearRemoteCodec.encodeResponse() |
static ClientMessage |
MultiMapLockCodec.encodeResponse() |
static ClientMessage |
MapEvictAllCodec.encodeResponse() |
static ClientMessage |
QueueClearCodec.encodeResponse() |
static ClientMessage |
ClientStatisticsCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddQueueConfigCodec.encodeResponse() |
static ClientMessage |
ClientDeployClassesCodec.encodeResponse() |
static ClientMessage |
MapPutAllCodec.encodeResponse() |
static ClientMessage |
TransactionalMapSetCodec.encodeResponse() |
static ClientMessage |
MapSetCodec.encodeResponse() |
static ClientMessage |
MapRemoveAllCodec.encodeResponse() |
static ClientMessage |
ScheduledExecutorSubmitToPartitionCodec.encodeResponse() |
static ClientMessage |
MapAddIndexCodec.encodeResponse() |
static ClientMessage |
DurableExecutorShutdownCodec.encodeResponse() |
static ClientMessage |
ReplicatedMapPutAllCodec.encodeResponse() |
static ClientMessage |
MapClearCodec.encodeResponse() |
static ClientMessage |
MapClearNearCacheCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddListConfigCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddCardinalityEstimatorConfigCodec.encodeResponse() |
static ClientMessage |
MapLoadGivenKeysCodec.encodeResponse() |
static ClientMessage |
CachePutAllCodec.encodeResponse() |
static ClientMessage |
ClientCreateProxiesCodec.encodeResponse() |
static ClientMessage |
CardinalityEstimatorAddCodec.encodeResponse() |
static ClientMessage |
ExecutorServiceShutdownCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddReplicatedMapConfigCodec.encodeResponse() |
static ClientMessage |
CacheRemoveAllKeysCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddMapConfigCodec.encodeResponse() |
static ClientMessage |
TransactionRollbackCodec.encodeResponse() |
static ClientMessage |
ScheduledExecutorShutdownCodec.encodeResponse() |
static ClientMessage |
ScheduledExecutorDisposeFromAddressCodec.encodeResponse() |
static ClientMessage |
CacheRemoveAllCodec.encodeResponse() |
static ClientMessage |
ScheduledExecutorDisposeFromPartitionCodec.encodeResponse() |
static ClientMessage |
DurableExecutorDisposeResultCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddCacheConfigCodec.encodeResponse() |
static ClientMessage |
XATransactionCommitCodec.encodeResponse() |
static ClientMessage |
CPSessionHeartbeatSessionCodec.encodeResponse() |
static ClientMessage |
DynamicConfigAddExecutorConfigCodec.encodeResponse() |
static ClientMessage |
CacheManagementConfigCodec.encodeResponse() |
static ClientMessage |
XATransactionRollbackCodec.encodeResponse() |
static ClientMessage |
TransactionCommitCodec.encodeResponse() |
static ClientMessage |
CacheLoadAllCodec.encodeResponse() |
static ClientMessage |
MapDeleteCodec.encodeResponse() |
static ClientMessage |
MapUnlockCodec.encodeResponse() |
static ClientMessage |
ClientCreateProxyCodec.encodeResponse() |
static ClientMessage |
QueueIsEmptyCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalMapReplaceIfSameCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalMapContainsValueCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueCompareAndRetainAllCodec.encodeResponse(boolean response) |
static ClientMessage |
MapRemovePartitionLostListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapContainsEntryCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalMapRemoveIfSameCodec.encodeResponse(boolean response) |
static ClientMessage |
ScheduledExecutorIsDoneFromAddressCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueContainsCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalMapIsEmptyCodec.encodeResponse(boolean response) |
static ClientMessage |
MapIsEmptyCodec.encodeResponse(boolean response) |
static ClientMessage |
ReplicatedMapRemoveEntryListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
ContinuousQueryMadePublishableCodec.encodeResponse(boolean response) |
static ClientMessage |
ScheduledExecutorCancelFromPartitionCodec.encodeResponse(boolean response) |
static ClientMessage |
MapContainsValueCodec.encodeResponse(boolean response) |
static ClientMessage |
ListRemoveListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
ContinuousQuerySetReadCursorCodec.encodeResponse(boolean response) |
static ClientMessage |
CacheRemoveInvalidationListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
DurableExecutorIsShutdownCodec.encodeResponse(boolean response) |
static ClientMessage |
AtomicRefContainsCodec.encodeResponse(boolean response) |
static ClientMessage |
SemaphoreChangeCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalMapContainsKeyCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueCompareAndRemoveAllCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalMultiMapRemoveEntryCodec.encodeResponse(boolean response) |
static ClientMessage |
ClientIsFailoverSupportedCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapContainsValueCodec.encodeResponse(boolean response) |
static ClientMessage |
ReplicatedMapContainsKeyCodec.encodeResponse(boolean response) |
static ClientMessage |
MapTryRemoveCodec.encodeResponse(boolean response) |
static ClientMessage |
FencedLockUnlockCodec.encodeResponse(boolean response) |
static ClientMessage |
ListIsEmptyCodec.encodeResponse(boolean response) |
static ClientMessage |
SetAddCodec.encodeResponse(boolean response) |
static ClientMessage |
ContinuousQueryDestroyCacheCodec.encodeResponse(boolean response) |
static ClientMessage |
ExecutorServiceCancelOnPartitionCodec.encodeResponse(boolean response) |
static ClientMessage |
ListAddAllCodec.encodeResponse(boolean response) |
static ClientMessage |
MapEvictCodec.encodeResponse(boolean response) |
static ClientMessage |
SemaphoreAcquireCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueRemoveCodec.encodeResponse(boolean response) |
static ClientMessage |
SetIsEmptyCodec.encodeResponse(boolean response) |
static ClientMessage |
TopicRemoveMessageListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
CacheSetExpiryPolicyCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapPutCodec.encodeResponse(boolean response) |
static ClientMessage |
ListAddCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueContainsAllCodec.encodeResponse(boolean response) |
static ClientMessage |
MapTryPutCodec.encodeResponse(boolean response) |
static ClientMessage |
SetContainsAllCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapRemoveEntryListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
MapReplaceIfSameCodec.encodeResponse(boolean response) |
static ClientMessage |
ReplicatedMapContainsValueCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueOfferCodec.encodeResponse(boolean response) |
static ClientMessage |
ListContainsCodec.encodeResponse(boolean response) |
static ClientMessage |
CountDownLatchAwaitCodec.encodeResponse(boolean response) |
static ClientMessage |
ListContainsAllCodec.encodeResponse(boolean response) |
static ClientMessage |
CacheContainsKeyCodec.encodeResponse(boolean response) |
static ClientMessage |
ExecutorServiceIsShutdownCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalSetRemoveCodec.encodeResponse(boolean response) |
static ClientMessage |
CacheRemoveCodec.encodeResponse(boolean response) |
static ClientMessage |
MapContainsKeyCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapRemoveEntryCodec.encodeResponse(boolean response) |
static ClientMessage |
MapRemoveEntryListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
SetCompareAndRemoveAllCodec.encodeResponse(boolean response) |
static ClientMessage |
ScheduledExecutorIsCancelledFromPartitionCodec.encodeResponse(boolean response) |
static ClientMessage |
AtomicRefCompareAndSetCodec.encodeResponse(boolean response) |
static ClientMessage |
MapSetTtlCodec.encodeResponse(boolean response) |
static ClientMessage |
SetCompareAndRetainAllCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalListAddCodec.encodeResponse(boolean response) |
static ClientMessage |
SetRemoveCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapContainsKeyCodec.encodeResponse(boolean response) |
static ClientMessage |
SemaphoreReleaseCodec.encodeResponse(boolean response) |
static ClientMessage |
ScheduledExecutorCancelFromAddressCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalSetAddCodec.encodeResponse(boolean response) |
static ClientMessage |
SemaphoreInitCodec.encodeResponse(boolean response) |
static ClientMessage |
ScheduledExecutorIsCancelledFromAddressCodec.encodeResponse(boolean response) |
static ClientMessage |
CPSessionCloseSessionCodec.encodeResponse(boolean response) |
static ClientMessage |
MapRemoveIfSameCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalQueueOfferCodec.encodeResponse(boolean response) |
static ClientMessage |
ReplicatedMapIsEmptyCodec.encodeResponse(boolean response) |
static ClientMessage |
SemaphoreGetSemaphoreTypeCodec.encodeResponse(boolean response) |
static ClientMessage |
SetRemoveListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
ListCompareAndRemoveAllCodec.encodeResponse(boolean response) |
static ClientMessage |
ScheduledExecutorIsDoneFromPartitionCodec.encodeResponse(boolean response) |
static ClientMessage |
ListAddAllWithIndexCodec.encodeResponse(boolean response) |
static ClientMessage |
ListRemoveCodec.encodeResponse(boolean response) |
static ClientMessage |
AtomicLongCompareAndSetCodec.encodeResponse(boolean response) |
static ClientMessage |
ExecutorServiceCancelOnAddressCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalListRemoveCodec.encodeResponse(boolean response) |
static ClientMessage |
SetAddAllCodec.encodeResponse(boolean response) |
static ClientMessage |
MapIsLockedCodec.encodeResponse(boolean response) |
static ClientMessage |
TransactionalMultiMapPutCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapIsLockedCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueAddAllCodec.encodeResponse(boolean response) |
static ClientMessage |
CountDownLatchTrySetCountCodec.encodeResponse(boolean response) |
static ClientMessage |
MapRemoveInterceptorCodec.encodeResponse(boolean response) |
static ClientMessage |
QueueRemoveListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
MultiMapTryLockCodec.encodeResponse(boolean response) |
static ClientMessage |
MapTryLockCodec.encodeResponse(boolean response) |
static ClientMessage |
ListCompareAndRetainAllCodec.encodeResponse(boolean response) |
static ClientMessage |
ClientRemoveDistributedObjectListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
CacheRemoveEntryListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
CacheRemovePartitionLostListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
SetContainsCodec.encodeResponse(boolean response) |
static ClientMessage |
CachePutIfAbsentCodec.encodeResponse(boolean response) |
static ClientMessage |
ClientRemovePartitionLostListenerCodec.encodeResponse(boolean response) |
static ClientMessage |
ClientAuthenticationCustomCodec.encodeResponse(byte status,
Address address,
UUID uuid,
byte serializationVersion,
String serverHazelcastVersion,
int partitionCount,
UUID clusterId) |
static ClientMessage |
ClientAuthenticationCodec.encodeResponse(byte status,
Address address,
UUID uuid,
byte serializationVersion,
String serverHazelcastVersion,
int partitionCount,
UUID clusterId) |
static ClientMessage |
CacheCreateConfigCodec.encodeResponse(CacheConfigHolder response) |
static ClientMessage |
CacheGetConfigCodec.encodeResponse(CacheConfigHolder response) |
static ClientMessage |
TransactionalMultiMapGetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
QueueDrainToMaxSizeCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMultiMapRemoveCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapProjectCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapValuesWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapKeySetWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
SetGetAllCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListListIteratorCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListSubCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
QueueIteratorCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapKeySetWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
QueueDrainToCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapRemoveCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapProjectWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListIteratorCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapValuesWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapGetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapKeySetWithPagingPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ContinuousQueryPublisherCreateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ReplicatedMapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListGetAllCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ReplicatedMapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapFetchWithQueryCodec.encodeResponse(Collection<Data> results,
int nextTableIndexToReadFrom) |
static ClientMessage |
ClientGetDistributedObjectsCodec.encodeResponse(Collection<DistributedObjectInfo> response) |
static ClientMessage |
ClientGetPartitionsCodec.encodeResponse(Collection<Map.Entry<Address,List<Integer>>> partitions,
int partitionStateVersion) |
static ClientMessage |
MapEntriesWithPagingPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteWithPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
CacheGetAllCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapValuesWithPagingPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MultiMapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapEntriesWithPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteOnKeysCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteOnAllKeysCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapGetAllCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
ContinuousQueryPublisherCreateWithValueCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
ReplicatedMapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
CacheAssignAndGetUuidsCodec.encodeResponse(Collection<Map.Entry<Integer,UUID>> partitionUuidList) |
static ClientMessage |
MapAssignAndGetUuidsCodec.encodeResponse(Collection<Map.Entry<Integer,UUID>> partitionUuidList) |
static ClientMessage |
MetricsReadMetricsCodec.encodeResponse(Collection<Map.Entry<Long,byte[]>> elements,
long nextSequence) |
static ClientMessage |
ScheduledExecutorGetAllScheduledFuturesCodec.encodeResponse(Collection<Map.Entry<Member,List<ScheduledTaskHandler>>> handlers) |
static ClientMessage |
CacheFetchNearCacheInvalidationMetadataCodec.encodeResponse(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList,
Collection<Map.Entry<Integer,UUID>> partitionUuidList) |
static ClientMessage |
MapFetchNearCacheInvalidationMetadataCodec.encodeResponse(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList,
Collection<Map.Entry<Integer,UUID>> partitionUuidList) |
static ClientMessage |
XATransactionCollectTransactionsCodec.encodeResponse(Collection<Xid> response) |
static ClientMessage |
TransactionalMapReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
ListGetCodec.encodeResponse(Data response) |
static ClientMessage |
MapAggregateCodec.encodeResponse(Data response) |
static ClientMessage |
ReplicatedMapPutCodec.encodeResponse(Data response) |
static ClientMessage |
CachePutCodec.encodeResponse(Data response) |
static ClientMessage |
MapSetWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
DurableExecutorRetrieveResultCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapGetForUpdateCodec.encodeResponse(Data response) |
static ClientMessage |
MapAggregateWithPredicateCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalQueueTakeCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicRefSetCodec.encodeResponse(Data response) |
static ClientMessage |
ReplicatedMapRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicRefGetCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutTransientWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
MapSubmitToKeyCodec.encodeResponse(Data response) |
static ClientMessage |
CacheEntryProcessorCodec.encodeResponse(Data response) |
static ClientMessage |
QueueTakeCodec.encodeResponse(Data response) |
static ClientMessage |
MapRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
QueuePollCodec.encodeResponse(Data response) |
static ClientMessage |
MapGetCodec.encodeResponse(Data response) |
static ClientMessage |
CacheGetCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapPutIfAbsentCodec.encodeResponse(Data response) |
static ClientMessage |
ScheduledExecutorGetResultFromPartitionCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutIfAbsentWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
ReplicatedMapGetCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalQueuePollCodec.encodeResponse(Data response) |
static ClientMessage |
ListRemoveWithIndexCodec.encodeResponse(Data response) |
static ClientMessage |
ExecutorServiceSubmitToAddressCodec.encodeResponse(Data response) |
static ClientMessage |
ScheduledExecutorGetResultFromAddressCodec.encodeResponse(Data response) |
static ClientMessage |
ExecutorServiceSubmitToPartitionCodec.encodeResponse(Data response) |
static ClientMessage |
RingbufferReadOneCodec.encodeResponse(Data response) |
static ClientMessage |
CacheGetAndReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
QueuePeekCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapPutCodec.encodeResponse(Data response) |
static ClientMessage |
MapExecuteOnKeyCodec.encodeResponse(Data response) |
static ClientMessage |
CacheReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalQueuePeekCodec.encodeResponse(Data response) |
static ClientMessage |
CacheGetAndRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicRefApplyCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
MapReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
ListSetCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicLongApplyCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapGetCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutIfAbsentCodec.encodeResponse(Data response) |
static ClientMessage |
DurableExecutorRetrieveAndDisposeResultCodec.encodeResponse(Data response) |
static ClientMessage |
ListSizeCodec.encodeResponse(int response) |
static ClientMessage |
CountDownLatchGetCountCodec.encodeResponse(int response) |
static ClientMessage |
TransactionalMapSizeCodec.encodeResponse(int response) |
static ClientMessage |
SemaphoreAvailablePermitsCodec.encodeResponse(int response) |
static ClientMessage |
ListLastIndexOfCodec.encodeResponse(int response) |
static ClientMessage |
MapSizeCodec.encodeResponse(int response) |
static ClientMessage |
SetSizeCodec.encodeResponse(int response) |
static ClientMessage |
CountDownLatchGetRoundCodec.encodeResponse(int response) |
static ClientMessage |
TransactionalListSizeCodec.encodeResponse(int response) |
static ClientMessage |
TransactionalMultiMapSizeCodec.encodeResponse(int response) |
static ClientMessage |
CacheSizeCodec.encodeResponse(int response) |
static ClientMessage |
MultiMapSizeCodec.encodeResponse(int response) |
static ClientMessage |
DurableExecutorSubmitToPartitionCodec.encodeResponse(int response) |
static ClientMessage |
QueueSizeCodec.encodeResponse(int response) |
static ClientMessage |
ListIndexOfCodec.encodeResponse(int response) |
static ClientMessage |
TransactionalSetSizeCodec.encodeResponse(int response) |
static ClientMessage |
PNCounterGetConfiguredReplicaCountCodec.encodeResponse(int response) |
static ClientMessage |
SemaphoreDrainCodec.encodeResponse(int response) |
static ClientMessage |
ReplicatedMapSizeCodec.encodeResponse(int response) |
static ClientMessage |
TransactionalQueueSizeCodec.encodeResponse(int response) |
static ClientMessage |
MultiMapValueCountCodec.encodeResponse(int response) |
static ClientMessage |
TransactionalMultiMapValueCountCodec.encodeResponse(int response) |
static ClientMessage |
QueueRemainingCapacityCodec.encodeResponse(int response) |
static ClientMessage |
CacheIterateCodec.encodeResponse(int tableIndex,
Collection<Data> keys) |
static ClientMessage |
MapFetchKeysCodec.encodeResponse(int tableIndex,
Collection<Data> keys) |
static ClientMessage |
CacheEventJournalReadCodec.encodeResponse(int readCount,
Collection<Data> items,
long[] itemSeqs,
long nextSeq) |
static ClientMessage |
RingbufferReadManyCodec.encodeResponse(int readCount,
Collection<Data> items,
long[] itemSeqs,
long nextSeq) |
static ClientMessage |
MapEventJournalReadCodec.encodeResponse(int readCount,
Collection<Data> items,
long[] itemSeqs,
long nextSeq) |
static ClientMessage |
CacheIterateEntriesCodec.encodeResponse(int tableIndex,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
MapFetchEntriesCodec.encodeResponse(int tableIndex,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
AtomicLongGetAndSetCodec.encodeResponse(long response) |
static ClientMessage |
ScheduledExecutorGetDelayFromAddressCodec.encodeResponse(long response) |
static ClientMessage |
RingbufferAddCodec.encodeResponse(long response) |
static ClientMessage |
AtomicLongAddAndGetCodec.encodeResponse(long response) |
static ClientMessage |
FencedLockLockCodec.encodeResponse(long response) |
static ClientMessage |
ScheduledExecutorGetDelayFromPartitionCodec.encodeResponse(long response) |
static ClientMessage |
CPSessionGenerateThreadIdCodec.encodeResponse(long response) |
static ClientMessage |
RingbufferAddAllCodec.encodeResponse(long response) |
static ClientMessage |
RingbufferSizeCodec.encodeResponse(long response) |
static ClientMessage |
AtomicLongGetAndAddCodec.encodeResponse(long response) |
static ClientMessage |
AtomicLongAlterCodec.encodeResponse(long response) |
static ClientMessage |
RingbufferRemainingCapacityCodec.encodeResponse(long response) |
static ClientMessage |
RingbufferCapacityCodec.encodeResponse(long response) |
static ClientMessage |
AtomicLongGetCodec.encodeResponse(long response) |
static ClientMessage |
RingbufferHeadSequenceCodec.encodeResponse(long response) |
static ClientMessage |
RingbufferTailSequenceCodec.encodeResponse(long response) |
static ClientMessage |
CardinalityEstimatorEstimateCodec.encodeResponse(long response) |
static ClientMessage |
FencedLockTryLockCodec.encodeResponse(long response) |
static ClientMessage |
PNCounterGetCodec.encodeResponse(long value,
Collection<Map.Entry<UUID,Long>> replicaTimestamps,
int replicaCount) |
static ClientMessage |
PNCounterAddCodec.encodeResponse(long value,
Collection<Map.Entry<UUID,Long>> replicaTimestamps,
int replicaCount) |
static ClientMessage |
FencedLockGetLockOwnershipCodec.encodeResponse(long fence,
int lockCount,
long sessionId,
long threadId) |
static ClientMessage |
CacheEventJournalSubscribeCodec.encodeResponse(long oldestSequence,
long newestSequence) |
static ClientMessage |
MapEventJournalSubscribeCodec.encodeResponse(long oldestSequence,
long newestSequence) |
static ClientMessage |
FlakeIdGeneratorNewIdBatchCodec.encodeResponse(long base,
long increment,
int batchSize) |
static ClientMessage |
CPSessionCreateSessionCodec.encodeResponse(long sessionId,
long ttlMillis,
long heartbeatMillis) |
static ClientMessage |
ScheduledExecutorGetStatsFromPartitionCodec.encodeResponse(long lastIdleTimeNanos,
long totalIdleTimeNanos,
long totalRuns,
long totalRunTimeNanos,
long lastRunDurationNanos) |
static ClientMessage |
ScheduledExecutorGetStatsFromAddressCodec.encodeResponse(long lastIdleTimeNanos,
long totalIdleTimeNanos,
long totalRuns,
long totalRunTimeNanos,
long lastRunDurationNanos) |
static ClientMessage |
CPGroupCreateCPGroupCodec.encodeResponse(RaftGroupId groupId) |
static ClientMessage |
MapGetEntryViewCodec.encodeResponse(SimpleEntryView<Data,Data> response,
long maxIdle) |
static ClientMessage |
MapAddInterceptorCodec.encodeResponse(String response) |
static ClientMessage |
TopicAddMessageListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.encodeResponse(UUID response) |
static ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateCodec.encodeResponse(UUID response) |
static ClientMessage |
MapAddEntryListenerToKeyCodec.encodeResponse(UUID response) |
static ClientMessage |
ClientAddPartitionLostListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
ClientAddDistributedObjectListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
MultiMapAddEntryListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
MapAddNearCacheEntryListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
XATransactionCreateCodec.encodeResponse(UUID response) |
static ClientMessage |
ListAddListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
CacheAddEntryListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
MapAddNearCacheInvalidationListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
ReplicatedMapAddNearCacheEntryListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
MapAddEntryListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
QueueAddListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
CacheAddInvalidationListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
MapAddEntryListenerWithPredicateCodec.encodeResponse(UUID response) |
static ClientMessage |
TransactionCreateCodec.encodeResponse(UUID response) |
static ClientMessage |
CacheAddNearCacheInvalidationListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
SetAddListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
MapAddEntryListenerToKeyWithPredicateCodec.encodeResponse(UUID response) |
static ClientMessage |
ClientAddMembershipListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
ContinuousQueryAddListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyCodec.encodeResponse(UUID response) |
static ClientMessage |
CacheAddPartitionLostListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
MultiMapAddEntryListenerToKeyCodec.encodeResponse(UUID response) |
static ClientMessage |
MapAddPartitionLostListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
ReplicatedMapAddEntryListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
ClientLocalBackupListenerCodec.encodeResponse(UUID response) |
static ClientMessage |
TopicAddMessageListenerCodec.encodeTopicEvent(Data item,
long publishTime,
UUID uuid) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ErrorsCodec.encode(List<ErrorHolder> errorHolders) |
Modifier and Type | Method and Description |
---|---|
static List<ErrorHolder> |
ErrorsCodec.decode(ClientMessage clientMessage) |
static void |
ByteArrayCodec.encode(ClientMessage clientMessage,
byte[] bytes) |
static void |
StringCodec.encode(ClientMessage clientMessage,
CacheSimpleConfig.ExpiryPolicyFactoryConfig.TimedExpiryPolicyFactoryConfig.ExpiryPolicyType expiryPolicyType) |
static void |
ListIntegerCodec.encode(ClientMessage clientMessage,
Collection<Integer> collection) |
static void |
ListLongCodec.encode(ClientMessage clientMessage,
Collection<Long> collection) |
static void |
EntryListIntegerLongCodec.encode(ClientMessage clientMessage,
Collection<Map.Entry<Integer,Long>> collection) |
static void |
EntryListIntegerUUIDCodec.encode(ClientMessage clientMessage,
Collection<Map.Entry<Integer,UUID>> collection) |
static <K,V> void |
EntryListCodec.encode(ClientMessage clientMessage,
Collection<Map.Entry<K,V>> collection,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static void |
EntryListLongByteArrayCodec.encode(ClientMessage clientMessage,
Collection<Map.Entry<Long,byte[]>> collection) |
static void |
EntryListUUIDLongCodec.encode(ClientMessage clientMessage,
Collection<Map.Entry<UUID,Long>> collection) |
static void |
ListScheduledTaskHandlerCodec.encode(ClientMessage clientMessage,
Collection<ScheduledTaskHandler> collection) |
static <T> void |
ListMultiFrameCodec.encode(ClientMessage clientMessage,
Collection<T> collection,
BiConsumer<ClientMessage,T> encodeFunction) |
static void |
ListUUIDCodec.encode(ClientMessage clientMessage,
Collection<UUID> collection) |
static void |
DataCodec.encode(ClientMessage clientMessage,
Data data) |
static void |
LongArrayCodec.encode(ClientMessage clientMessage,
long[] array) |
static <K,V> void |
MapCodec.encode(ClientMessage clientMessage,
Map<K,V> map,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static void |
StringCodec.encode(ClientMessage clientMessage,
String value) |
static void |
StringCodec.encode(ClientMessage clientMessage,
TimeUnit timeUnit) |
static <T> void |
ListMultiFrameCodec.encodeContainsNullable(ClientMessage clientMessage,
Collection<T> collection,
BiConsumer<ClientMessage,T> encodeFunction) |
static <K,V> void |
EntryListCodec.encodeNullable(ClientMessage clientMessage,
Collection<Map.Entry<K,V>> collection,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <T> void |
ListMultiFrameCodec.encodeNullable(ClientMessage clientMessage,
Collection<T> collection,
BiConsumer<ClientMessage,T> encodeFunction) |
static <K,V> void |
MapCodec.encodeNullable(ClientMessage clientMessage,
Map<K,V> map,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <T> void |
CodecUtil.encodeNullable(ClientMessage clientMessage,
T value,
BiConsumer<ClientMessage,T> encode) |
Modifier and Type | Method and Description |
---|---|
static <K,V> void |
EntryListCodec.encode(ClientMessage clientMessage,
Collection<Map.Entry<K,V>> collection,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <K,V> void |
EntryListCodec.encode(ClientMessage clientMessage,
Collection<Map.Entry<K,V>> collection,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <T> void |
ListMultiFrameCodec.encode(ClientMessage clientMessage,
Collection<T> collection,
BiConsumer<ClientMessage,T> encodeFunction) |
static <K,V> void |
MapCodec.encode(ClientMessage clientMessage,
Map<K,V> map,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <K,V> void |
MapCodec.encode(ClientMessage clientMessage,
Map<K,V> map,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <T> void |
ListMultiFrameCodec.encodeContainsNullable(ClientMessage clientMessage,
Collection<T> collection,
BiConsumer<ClientMessage,T> encodeFunction) |
static <K,V> void |
EntryListCodec.encodeNullable(ClientMessage clientMessage,
Collection<Map.Entry<K,V>> collection,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <K,V> void |
EntryListCodec.encodeNullable(ClientMessage clientMessage,
Collection<Map.Entry<K,V>> collection,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <T> void |
ListMultiFrameCodec.encodeNullable(ClientMessage clientMessage,
Collection<T> collection,
BiConsumer<ClientMessage,T> encodeFunction) |
static <K,V> void |
MapCodec.encodeNullable(ClientMessage clientMessage,
Map<K,V> map,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <K,V> void |
MapCodec.encodeNullable(ClientMessage clientMessage,
Map<K,V> map,
BiConsumer<ClientMessage,K> encodeKeyFunc,
BiConsumer<ClientMessage,V> encodeValueFunc) |
static <T> void |
CodecUtil.encodeNullable(ClientMessage clientMessage,
T value,
BiConsumer<ClientMessage,T> encode) |
Modifier and Type | Method and Description |
---|---|
static void |
AddressCodec.encode(ClientMessage clientMessage,
Address address) |
static void |
AttributeConfigCodec.encode(ClientMessage clientMessage,
AttributeConfig attributeConfig) |
static void |
CacheConfigHolderCodec.encode(ClientMessage clientMessage,
CacheConfigHolder cacheConfigHolder) |
static void |
CacheEventDataCodec.encode(ClientMessage clientMessage,
CacheEventData cacheEventData) |
static void |
DurationConfigCodec.encode(ClientMessage clientMessage,
CacheSimpleConfig.ExpiryPolicyFactoryConfig.DurationConfig durationConfig) |
static void |
TimedExpiryPolicyFactoryConfigCodec.encode(ClientMessage clientMessage,
CacheSimpleConfig.ExpiryPolicyFactoryConfig.TimedExpiryPolicyFactoryConfig timedExpiryPolicyFactoryConfig) |
static void |
CacheSimpleEntryListenerConfigCodec.encode(ClientMessage clientMessage,
CacheSimpleEntryListenerConfig cacheSimpleEntryListenerConfig) |
static void |
DistributedObjectInfoCodec.encode(ClientMessage clientMessage,
DistributedObjectInfo distributedObjectInfo) |
static void |
ErrorHolderCodec.encode(ClientMessage clientMessage,
ErrorHolder errorHolder) |
static void |
EventJournalConfigCodec.encode(ClientMessage clientMessage,
EventJournalConfig eventJournalConfig) |
static void |
EvictionConfigHolderCodec.encode(ClientMessage clientMessage,
EvictionConfigHolder evictionConfigHolder) |
static void |
HotRestartConfigCodec.encode(ClientMessage clientMessage,
HotRestartConfig hotRestartConfig) |
static void |
IndexConfigCodec.encode(ClientMessage clientMessage,
IndexConfig indexConfig) |
static void |
ListenerConfigHolderCodec.encode(ClientMessage clientMessage,
ListenerConfigHolder listenerConfigHolder) |
static void |
MapStoreConfigHolderCodec.encode(ClientMessage clientMessage,
MapStoreConfigHolder mapStoreConfigHolder) |
static void |
MemberCodec.encode(ClientMessage clientMessage,
Member member) |
static void |
MergePolicyConfigCodec.encode(ClientMessage clientMessage,
MergePolicyConfig mergePolicyConfig) |
static void |
MerkleTreeConfigCodec.encode(ClientMessage clientMessage,
MerkleTreeConfig merkleTreeConfig) |
static void |
NearCacheConfigHolderCodec.encode(ClientMessage clientMessage,
NearCacheConfigHolder nearCacheConfigHolder) |
static void |
NearCachePreloaderConfigCodec.encode(ClientMessage clientMessage,
NearCachePreloaderConfig nearCachePreloaderConfig) |
static void |
PredicateConfigHolderCodec.encode(ClientMessage clientMessage,
PredicateConfigHolder predicateConfigHolder) |
static void |
QueryCacheConfigHolderCodec.encode(ClientMessage clientMessage,
QueryCacheConfigHolder queryCacheConfigHolder) |
static void |
QueryCacheEventDataCodec.encode(ClientMessage clientMessage,
QueryCacheEventData queryCacheEventData) |
static void |
QueueStoreConfigHolderCodec.encode(ClientMessage clientMessage,
QueueStoreConfigHolder queueStoreConfigHolder) |
static void |
RaftGroupIdCodec.encode(ClientMessage clientMessage,
RaftGroupId raftGroupId) |
static void |
RingbufferStoreConfigHolderCodec.encode(ClientMessage clientMessage,
RingbufferStoreConfigHolder ringbufferStoreConfigHolder) |
static void |
ScheduledTaskHandlerCodec.encode(ClientMessage clientMessage,
ScheduledTaskHandler scheduledTaskHandler) |
static void |
SimpleEntryViewCodec.encode(ClientMessage clientMessage,
SimpleEntryView<Data,Data> simpleEntryView) |
static void |
StackTraceElementCodec.encode(ClientMessage clientMessage,
StackTraceElement stackTraceElement) |
static void |
WanReplicationRefCodec.encode(ClientMessage clientMessage,
WanReplicationRef wanReplicationRef) |
static void |
XidCodec.encode(ClientMessage clientMessage,
Xid xid) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
AbstractMessageTask.clientMessage |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
NoSuchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
AuthenticationMessageTask.encodeAuth(byte status,
Address thisAddress,
UUID uuid,
byte version,
int partitionCount,
UUID clusterId) |
protected abstract ClientMessage |
AuthenticationBaseMessageTask.encodeAuth(byte status,
Address thisAddress,
UUID uuid,
byte serializationVersion,
int partitionCount,
UUID clusterId) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeAuth(byte status,
Address thisAddress,
UUID uuid,
byte version,
int partitionCount,
UUID clusterId) |
protected ClientMessage |
PingMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddDistributedObjectListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddMembershipListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetPartitionsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddPartitionListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AuthenticationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveAllListenersMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateProxiesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DestroyProxyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetDistributedObjectsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddBackupListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RemoveDistributedObjectListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ClientStatisticsMessageTask.encodeResponse(Object response) |
protected abstract ClientMessage |
AbstractMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DeployClassesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
NoSuchMessageTask.encodeResponse(Object response) |
protected ClientMessage |
IsFailoverSupportedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateProxyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CacheDestroyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEventJournalSubscribeTask.encodeResponse(Object response) |
protected ClientMessage |
Pre38CacheAddInvalidationListenerTask.encodeResponse(Object response) |
protected ClientMessage |
CacheIterateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheSetExpiryPolicyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheListenerRegistrationMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEntryProcessorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAssignAndGetUuidsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CachePutAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheAddNearCacheInvalidationListenerTask.encodeResponse(Object response) |
protected ClientMessage |
CacheContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheCreateConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheEventJournalReadTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveInvalidationListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheGetAndRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheManagementConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheFetchNearCacheInvalidationMetadataTask.encodeResponse(Object response) |
protected ClientMessage |
CacheIterateEntriesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CacheRemoveAllKeysMessageTask.reduce(Map<Integer,Object> map) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
CardinalityEstimatorEstimateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CardinalityEstimatorAddMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected CardinalityEstimatorEstimateCodec.RequestParameters |
CardinalityEstimatorEstimateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CardinalityEstimatorAddCodec.RequestParameters |
CardinalityEstimatorAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CardinalityEstimatorAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CardinalityEstimatorEstimateMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
PNCounterGetConfiguredReplicaCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
PNCounterGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
PNCounterAddMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected PNCounterGetConfiguredReplicaCountCodec.RequestParameters |
PNCounterGetConfiguredReplicaCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected PNCounterGetCodec.RequestParameters |
PNCounterGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected PNCounterAddCodec.RequestParameters |
PNCounterAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
PNCounterAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
PNCounterGetConfiguredReplicaCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
PNCounterGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AddQueueConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddCacheConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddFlakeIdGeneratorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddSetConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddExecutorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddScheduledExecutorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddRingbufferConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddMultiMapConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddReplicatedMapConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddDurableExecutorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddMapConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddReliableTopicConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddListConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddCardinalityEstimatorConfigMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddTopicConfigMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ExecutorServiceIsShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceCancelOnAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ExecutorServiceSubmitToAddressMessageTask.encodeResponse(Object response) |
Constructor and Description |
---|
ExecutorServiceCancelOnAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceCancelOnPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToAddressMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ExecutorServiceSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
DurableExecutorRetrieveAndDisposeResultMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorRetrieveResultMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorIsShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorSubmitToPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DurableExecutorDisposeResultMessageTask.encodeResponse(Object response) |
Constructor and Description |
---|
DurableExecutorDisposeResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorIsShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorRetrieveAndDisposeResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorRetrieveResultMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorShutdownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DurableExecutorSubmitToPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListLastIndexOfMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListListIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSubMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListRemoveWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListAddAllWithIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ListClearMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractMapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MapAddNearCacheInvalidationListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
Pre38MapAddNearCacheEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapPutAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchNearCacheInvalidationMetadataTask.encodeResponse(Object response) |
protected ClientMessage |
MapPublisherCreateWithValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddIndexMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFlushMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapDestroyCacheMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchWithQueryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntriesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddPartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutTransientWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveInterceptorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPublisherCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutTransientMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEventJournalReadTask.encodeResponse(Object response) |
protected ClientMessage |
MapGetEntryViewMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddNearCacheInvalidationListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnAllKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemovePartitionLostListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
Pre38MapAddNearCacheEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAggregateWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetTtlMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapLoadGivenKeysMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEventJournalSubscribeTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSubmitToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapExecuteOnKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapSetReadCursorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapFetchEntriesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPagingPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapPutIfAbsentWithMaxIdleMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapMadePublishableMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapTryRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapProjectionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapProjectionWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapEvictMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapValuesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAssignAndGetUuidsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MapAggregateMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ReadMetricsMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected MetricsReadMetricsCodec.RequestParameters |
ReadMetricsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
ReadMetricsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
UUID uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
UUID uuid,
int numberOfEntriesAffected) |
protected abstract ClientMessage |
AbstractMultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
UUID uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapForceUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapValueCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapUnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapIsLockedMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapContainsEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapTryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
MultiMapKeySetMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
QueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueOfferMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMaxSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIteratorMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemainingCapacityMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueCompareAndRetainAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
QueueDrainMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ReplicatedMapAddNearCacheListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddNearCacheListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapEntrySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsValueMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReplicatedMapPutAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
RingbufferTailSequenceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferReadOneMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferHeadSequenceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferRemainingCapacityMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferReadManyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
RingbufferCapacityMessageTask.encodeResponse(Object response) |
Constructor and Description |
---|
RingbufferAddAllMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferHeadSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadManyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferReadOneMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferRemainingCapacityMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
RingbufferTailSequenceMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ScheduledExecutorTaskIsDoneFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskDisposeFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorSubmitToAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorGetAllScheduledMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskIsDoneFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetDelayFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetResultFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetDelayFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskCancelFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetResultFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorShutdownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetStatisticsFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskIsCancelledFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskGetStatisticsFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskCancelFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskDisposeFromPartitionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorTaskIsCancelledFromAddressMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ScheduledExecutorSubmitToPartitionMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
SetContainsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetGetAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetClearMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRemoveAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetRemoveListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetContainsAllMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetIsEmptyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetCompareAndRetainAllMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TopicRemoveMessageListenerMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicPublishMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TopicAddMessageListenerMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected TopicRemoveMessageListenerCodec.RequestParameters |
TopicRemoveMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TopicPublishCodec.RequestParameters |
TopicPublishMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TopicAddMessageListenerCodec.RequestParameters |
TopicAddMessageListenerMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicPublishMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
XATransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAClearRemoteTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCommitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XAFinalizeTransactionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionPrepareMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XACollectTransactionsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionRollbackMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionCreateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
XATransactionCommitMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalListAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalListSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected TransactionalListAddCodec.RequestParameters |
TransactionalListAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalListRemoveCodec.RequestParameters |
TransactionalListRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalListSizeCodec.RequestParameters |
TransactionalListSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalListAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalListSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMapValuesWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapValuesMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapKeySetWithPredicateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapContainsKeyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapDeleteMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutIfAbsentMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveIfSameMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapGetForUpdateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapReplaceMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMapIsEmptyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalMultiMapPutMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveEntryMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalMultiMapValueCountMessageTask.encodeResponse(Object response) |
Constructor and Description |
---|
TransactionalMultiMapGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapPutMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveEntryMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalMultiMapValueCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalQueuePollMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueTakeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueSizeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueuePeekMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalQueueOfferMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected TransactionalQueuePollCodec.RequestParameters |
TransactionalQueuePollMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalQueueTakeCodec.RequestParameters |
TransactionalQueueTakeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalQueueSizeCodec.RequestParameters |
TransactionalQueueSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalQueuePeekCodec.RequestParameters |
TransactionalQueuePeekMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalQueueOfferCodec.RequestParameters |
TransactionalQueueOfferMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalQueueOfferMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePeekMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueuePollMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalQueueTakeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TransactionalSetRemoveMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TransactionalSetSizeMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected TransactionalSetRemoveCodec.RequestParameters |
TransactionalSetRemoveMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalSetAddCodec.RequestParameters |
TransactionalSetAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected TransactionalSetSizeCodec.RequestParameters |
TransactionalSetSizeMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
TransactionalSetAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TransactionalSetSizeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
static List<ClientMessage> |
ClientMessageSplitter.getFragments(int maxFrameSize,
ClientMessage clientMessage)
Splits a
ClientMessage into fragments of a maximum size. |
Modifier and Type | Method and Description |
---|---|
static List<ClientMessage> |
ClientMessageSplitter.getFragments(int maxFrameSize,
ClientMessage clientMessage)
Splits a
ClientMessage into fragments of a maximum size. |
Constructor and Description |
---|
ClientMessageDecoder(Connection connection,
Consumer<ClientMessage> dst,
HazelcastProperties properties) |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
ClientRingbufferProxy.invoke(ClientMessage clientMessage,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ClientTransactionUtil.invoke(ClientMessage request,
Object objectName,
HazelcastClientInstanceImpl client,
Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions.
|
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
ClientTransactionUtil.invoke(ClientMessage request,
Object objectName,
HazelcastClientInstanceImpl client,
Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions.
|
Modifier and Type | Method and Description |
---|---|
Consumer<ClientMessage> |
ClientInvocationService.getResponseHandler() |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
ClientProxy.invoke(ClientMessage clientMessage) |
protected <T> T |
ClientProxy.invoke(ClientMessage clientMessage,
Object key) |
protected <T> T |
ClientProxy.invokeOnAddress(ClientMessage clientMessage,
Address address) |
protected <T> T |
ClientProxy.invokeOnPartition(ClientMessage clientMessage,
int partitionId) |
protected <T> T |
ClientProxy.invokeOnPartitionInterruptibly(ClientMessage clientMessage,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ListenerMessageCodec.encodeAddRequest(boolean localOnly) |
ClientMessage |
ListenerMessageCodec.encodeRemoveRequest(UUID realRegistrationId) |
ClientMessage |
ClientInvocation.getClientMessage() |
ClientMessage |
ClientInvocationFuture.resolveAndThrowIfException(Object response) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<ClientMessage> |
ClientInvocationFuture.exceptionally(Function<Throwable,? extends ClientMessage> fn) |
Consumer<ClientMessage> |
ClientResponseHandlerSupplier.get() |
Consumer<ClientMessage> |
AbstractClientInvocationService.getResponseHandler() |
InternalCompletableFuture<ClientMessage> |
ClientInvocationFuture.whenCompleteAsync(BiConsumer<? super ClientMessage,? super Throwable> action,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
UUID |
ListenerMessageCodec.decodeAddResponse(ClientMessage clientMessage) |
boolean |
ListenerMessageCodec.decodeRemoveResponse(ClientMessage clientMessage) |
Constructor and Description |
---|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName)
Create an invocation that will be executed on random member.
|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
Address address)
Create an invocation that will be executed on member with given
address . |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
Connection connection)
Create an invocation that will be executed on given
connection . |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
int partitionId)
Create an invocation that will be executed on owner of
partitionId . |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
int partitionId,
Address address,
Connection connection) |
ClientInvocationFuture(ClientInvocation invocation,
ClientMessage request,
ILogger logger,
CallIdSequence callIdSequence) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClientListenerService.handleEventMessage(ClientMessage clientMessage) |
void |
AbstractClientListenerService.handleEventMessageOnCallingThread(ClientMessage clientMessage) |
Constructor and Description |
---|
AbstractCPMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
GetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetAndAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AlterMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AddAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ApplyMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected AtomicLongGetCodec.RequestParameters |
GetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicLongGetAndAddCodec.RequestParameters |
GetAndAddMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicLongAlterCodec.RequestParameters |
AlterMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicLongGetAndSetCodec.RequestParameters |
GetAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicLongCompareAndSetCodec.RequestParameters |
CompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicLongAddAndGetCodec.RequestParameters |
AddAndGetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicLongApplyCodec.RequestParameters |
ApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AddAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
AlterMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ApplyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CompareAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetAndAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
GetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CompareAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ApplyMessageTask.encodeResponse(Object response) |
protected ClientMessage |
SetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ContainsMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected AtomicRefGetCodec.RequestParameters |
GetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicRefCompareAndSetCodec.RequestParameters |
CompareAndSetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicRefApplyCodec.RequestParameters |
ApplyMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicRefSetCodec.RequestParameters |
SetMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected AtomicRefContainsCodec.RequestParameters |
ContainsMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
ApplyMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CompareAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ContainsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
SetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
TrySetCountMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AwaitMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CountDownMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetRoundMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetCountMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected CountDownLatchTrySetCountCodec.RequestParameters |
TrySetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CountDownLatchAwaitCodec.RequestParameters |
AwaitMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CountDownLatchCountDownCodec.RequestParameters |
CountDownMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CountDownLatchGetRoundCodec.RequestParameters |
GetRoundMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CountDownLatchGetRoundCodec.RequestParameters |
GetCountMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
AwaitMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CountDownMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetRoundMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TrySetCountMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
UnlockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetLockOwnershipStateMessageTask.encodeResponse(Object response) |
protected ClientMessage |
TryLockMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LockMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected FencedLockUnlockCodec.RequestParameters |
UnlockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected FencedLockGetLockOwnershipCodec.RequestParameters |
GetLockOwnershipStateMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected FencedLockTryLockCodec.RequestParameters |
TryLockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected FencedLockLockCodec.RequestParameters |
LockMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
GetLockOwnershipStateMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
TryLockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
UnlockMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ChangePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GetSemaphoreTypeMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AvailablePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
AcquirePermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
DrainPermitsMessageTask.encodeResponse(Object response) |
protected ClientMessage |
InitSemaphoreMessageTask.encodeResponse(Object response) |
protected ClientMessage |
ReleasePermitsMessageTask.encodeResponse(Object response) |
Constructor and Description |
---|
AcquirePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
AvailablePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ChangePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DrainPermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GetSemaphoreTypeMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
InitSemaphoreMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
ReleasePermitsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
DestroyRaftObjectMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateRaftGroupMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected CPGroupDestroyCPObjectCodec.RequestParameters |
DestroyRaftObjectMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CPGroupCreateCPGroupCodec.RequestParameters |
CreateRaftGroupMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CreateRaftGroupMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
DestroyRaftObjectMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
HeartbeatSessionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
GenerateThreadIdMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CloseSessionMessageTask.encodeResponse(Object response) |
protected ClientMessage |
CreateSessionMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected CPSessionHeartbeatSessionCodec.RequestParameters |
HeartbeatSessionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CPSessionGenerateThreadIdCodec.RequestParameters |
GenerateThreadIdMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CPSessionCloseSessionCodec.RequestParameters |
CloseSessionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
protected CPSessionCreateSessionCodec.RequestParameters |
CreateSessionMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
CloseSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
CreateSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
GenerateThreadIdMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
HeartbeatSessionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
NewIdBatchMessageTask.encodeResponse(Object response) |
Modifier and Type | Method and Description |
---|---|
protected FlakeIdGeneratorNewIdBatchCodec.RequestParameters |
NewIdBatchMessageTask.decodeClientMessage(ClientMessage clientMessage) |
Constructor and Description |
---|
NewIdBatchMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
LongRegisterGetCodec.encodeRequest(String name) |
static ClientMessage |
LongRegisterIncrementAndGetCodec.encodeRequest(String name) |
static ClientMessage |
LongRegisterGetAndIncrementCodec.encodeRequest(String name) |
static ClientMessage |
LongRegisterDecrementAndGetCodec.encodeRequest(String name) |
static ClientMessage |
LongRegisterGetAndSetCodec.encodeRequest(String name,
long newValue) |
static ClientMessage |
LongRegisterGetAndAddCodec.encodeRequest(String name,
long delta) |
static ClientMessage |
LongRegisterSetCodec.encodeRequest(String name,
long newValue) |
static ClientMessage |
LongRegisterAddAndGetCodec.encodeRequest(String name,
long delta) |
static ClientMessage |
LongRegisterSetCodec.encodeResponse() |
static ClientMessage |
LongRegisterGetAndSetCodec.encodeResponse(long response) |
static ClientMessage |
LongRegisterGetAndAddCodec.encodeResponse(long response) |
static ClientMessage |
LongRegisterGetCodec.encodeResponse(long response) |
static ClientMessage |
LongRegisterIncrementAndGetCodec.encodeResponse(long response) |
static ClientMessage |
LongRegisterGetAndIncrementCodec.encodeResponse(long response) |
static ClientMessage |
LongRegisterAddAndGetCodec.encodeResponse(long response) |
static ClientMessage |
LongRegisterDecrementAndGetCodec.encodeResponse(long response) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
LongRegisterIncrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LongRegisterGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LongRegisterAddAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LongRegisterSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LongRegisterDecrementAndGetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LongRegisterGetAndAddMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LongRegisterGetAndSetMessageTask.encodeResponse(Object response) |
protected ClientMessage |
LongRegisterGetAndIncrementMessageTask.encodeResponse(Object response) |
Constructor and Description |
---|
LongRegisterAddAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterDecrementAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetAndAddMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetAndIncrementMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetAndSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterIncrementAndGetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
LongRegisterSetMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected abstract ClientMessage |
AbstractBaseNearCacheInvalidationListener.encodeBatchInvalidation(String name,
List<Data> keys,
List<UUID> sourceUuids,
List<UUID> partitionUuids,
List<Long> sequences) |
protected abstract ClientMessage |
AbstractBaseNearCacheInvalidationListener.encodeSingleInvalidation(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractBaseNearCacheInvalidationListener.sendMessageWithOrderKey(ClientMessage clientMessage,
Object orderKey) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.