| Package | Description | 
|---|---|
| com.hazelcast.client | 
 Contains classes/interfaces related to Client 
 | 
| com.hazelcast.client.connection | 
 Provides connection interfaces/classes for com.hazelcast.client 
 | 
| com.hazelcast.client.connection.nio | 
 Contains classes related to New IO for com.hazelcast.client.connection 
 | 
| com.hazelcast.client.impl | 
 Contains most of the client side HazelcastInstance implementation functionality. 
 | 
| com.hazelcast.client.impl.protocol | 
 Client protocol related private implementation classes 
 | 
| com.hazelcast.client.impl.protocol.task | 
 Client tasks associated with requests. 
 | 
| com.hazelcast.client.impl.protocol.task.atomiclong | 
 Client protocol tasks implementations for AtomicLong 
 | 
| com.hazelcast.client.impl.protocol.task.atomicreference | 
 Client protocol tasks implementations for AtomicReference 
 | 
| com.hazelcast.client.impl.protocol.task.cache | 
 Client protocol tasks implementations for JCache 
 | 
| com.hazelcast.client.impl.protocol.task.cardinality | |
| com.hazelcast.client.impl.protocol.task.condition | 
 Client protocol tasks implementations for Condition 
 | 
| com.hazelcast.client.impl.protocol.task.countdownlatch | 
 Client protocol tasks implementations for CountDownLatch 
 | 
| com.hazelcast.client.impl.protocol.task.crdt.pncounter | |
| com.hazelcast.client.impl.protocol.task.dynamicconfig | |
| com.hazelcast.client.impl.protocol.task.executorservice | 
 Client protocol tasks implementations for ExecutorService 
 | 
| com.hazelcast.client.impl.protocol.task.executorservice.durable | |
| com.hazelcast.client.impl.protocol.task.list | 
 Client protocol tasks implementations for List 
 | 
| com.hazelcast.client.impl.protocol.task.lock | 
 Client protocol tasks implementations for ILock 
 | 
| com.hazelcast.client.impl.protocol.task.map | 
 Client protocol tasks implementations for map 
 | 
| com.hazelcast.client.impl.protocol.task.mapreduce | 
 Client protocol tasks implementations for map reduce 
 | 
| com.hazelcast.client.impl.protocol.task.multimap | 
 Client protocol tasks implementations for multi map 
 | 
| com.hazelcast.client.impl.protocol.task.queue | 
 Client protocol tasks implementations for Queue 
 | 
| com.hazelcast.client.impl.protocol.task.replicatedmap | 
 Client protocol tasks implementations for ReplicatedMap 
 | 
| com.hazelcast.client.impl.protocol.task.ringbuffer | 
 Client protocol tasks implementations for Ringbuffer 
 | 
| com.hazelcast.client.impl.protocol.task.scheduledexecutor | |
| com.hazelcast.client.impl.protocol.task.semaphore | 
 Client protocol tasks implementations for Semaphore 
 | 
| com.hazelcast.client.impl.protocol.task.set | 
 Client protocol tasks implementations for set 
 | 
| com.hazelcast.client.impl.protocol.task.topic | 
 Client protocol tasks implementations for Topic 
 | 
| com.hazelcast.client.impl.protocol.task.transaction | 
 Client protocol tasks implementations for Transaction related 
 | 
| com.hazelcast.client.impl.protocol.task.transactionallist | 
 Client protocol tasks implementations for Transactional List 
 | 
| com.hazelcast.client.impl.protocol.task.transactionalmap | 
 Client protocol tasks implementations for Transactional Map 
 | 
| com.hazelcast.client.impl.protocol.task.transactionalmultimap | 
 Client protocol tasks implementations for Transactional MultiMap 
 | 
| com.hazelcast.client.impl.protocol.task.transactionalqueue | 
 Client protocol tasks implementations for Transactional Queue 
 | 
| com.hazelcast.client.impl.protocol.task.transactionalset | 
 Client protocol tasks implementations for Transactional Set 
 | 
| com.hazelcast.client.impl.protocol.util | 
 Protocol utils 
 | 
| com.hazelcast.client.proxy.txn | 
 Contains classes related to proxy for client transactions 
 | 
| com.hazelcast.client.spi | 
 Contains classes/interfaces related to the Hazelcast client Service Provider Interface. 
 | 
| com.hazelcast.client.spi.impl | 
 Provides util classes for the Hazelcast client SPI. 
 | 
| com.hazelcast.client.spi.impl.listener | |
| com.hazelcast.flakeidgen.impl.client | |
| com.hazelcast.internal.cluster.impl | 
 This package contains the implementation of the cluster functionality. 
 | 
| com.hazelcast.nio | 
 This package contains classes related to New IO 
 | 
| com.hazelcast.nio.tcp | 
 Contains functionality for the TCP/IP Networking for cluster members 
This whole package is internal and no compatibility will be provided.  | 
| com.hazelcast.spi | 
 Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services. 
 | 
| com.hazelcast.spi.impl.operationservice.impl | 
 Contains the code for the  
InternalOperationService implementation. | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
ClientEndpoint.getConnection()  | 
| Modifier and Type | Method and Description | 
|---|---|
ClientEndpoint | 
ClientEndpointManager.getEndpoint(Connection connection)
Gets the endpoint for a given connection. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
ClientConnectionManager.getActiveConnection(Address address)  | 
Connection | 
ClientConnectionManager.getOrConnect(Address address)  | 
Connection | 
ClientConnectionManager.getOrTriggerConnect(Address address,
                   boolean acquiresResource)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ClientConnection
Client implementation of  
Connection. | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
ClientConnectionManagerImpl.getActiveConnection(Address target)  | 
Connection | 
ClientConnectionManagerImpl.getOrConnect(Address address)  | 
Connection | 
ClientConnectionManagerImpl.getOrTriggerConnect(Address target,
                   boolean acquiresResources)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClientICMPManager.connectionAdded(Connection connection)  | 
void | 
ClientICMPManager.connectionRemoved(Connection connection)  | 
void | 
ClientConnectionManagerImpl.heartbeatResumed(Connection connection)  | 
void | 
ClientConnectionManagerImpl.heartbeatStopped(Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
ClientEndpointImpl.getConnection()  | 
| Modifier and Type | Method and Description | 
|---|---|
MessageTask | 
CompositeMessageTaskFactory.create(ClientMessage clientMessage,
      Connection connection)  | 
ClientEndpoint | 
ClientEndpointManagerImpl.getEndpoint(Connection connection)  | 
void | 
ClientEngineImpl.handle(ClientMessage clientMessage,
      Connection connection)  | 
void | 
HazelcastClientInstanceImpl.onClusterConnect(Connection ownerConnection)  | 
| Constructor and Description | 
|---|
ClientEndpointImpl(ClientEngineImpl clientEngine,
                  NodeEngineImpl nodeEngine,
                  Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
MessageTask | 
MessageTaskFactory.create(ClientMessage clientMessage,
      Connection connection)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected Connection | 
AbstractMessageTask.connection  | 
| Constructor and Description | 
|---|
CardinalityEstimatorAddMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection)  | 
CardinalityEstimatorEstimateMessageTask(ClientMessage clientMessage,
                                       Node node,
                                       Connection connection)  | 
| Constructor and Description | 
|---|
ConditionAwaitMessageTask(ClientMessage clientMessage,
                         Node node,
                         Connection connection)  | 
ConditionBeforeAwaitMessageTask(ClientMessage clientMessage,
                               Node node,
                               Connection connection)  | 
ConditionSignalAllMessageTask(ClientMessage clientMessage,
                             Node node,
                             Connection connection)  | 
ConditionSignalMessageTask(ClientMessage clientMessage,
                          Node node,
                          Connection connection)  | 
| Constructor and Description | 
|---|
CountDownLatchAwaitMessageTask(ClientMessage clientMessage,
                              Node node,
                              Connection connection)  | 
CountDownLatchCountDownMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection)  | 
CountDownLatchGetCountMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection)  | 
CountDownLatchTrySetCountMessageTask(ClientMessage clientMessage,
                                    Node node,
                                    Connection connection)  | 
| Constructor and Description | 
|---|
PNCounterAddMessageTask(ClientMessage clientMessage,
                       Node node,
                       Connection connection)  | 
PNCounterGetConfiguredReplicaCountMessageTask(ClientMessage clientMessage,
                                             Node node,
                                             Connection connection)  | 
PNCounterGetMessageTask(ClientMessage clientMessage,
                       Node node,
                       Connection connection)  | 
| Constructor and Description | 
|---|
AbstractExecutorServiceCancelMessageTask(ClientMessage clientMessage,
                                        Node node,
                                        Connection connection)  | 
ExecutorServiceCancelOnAddressMessageTask(ClientMessage clientMessage,
                                         Node node,
                                         Connection connection)  | 
ExecutorServiceCancelOnPartitionMessageTask(ClientMessage clientMessage,
                                           Node node,
                                           Connection connection)  | 
ExecutorServiceIsShutdownMessageTask(ClientMessage clientMessage,
                                    Node node,
                                    Connection connection)  | 
ExecutorServiceShutdownMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection)  | 
ExecutorServiceSubmitToAddressMessageTask(ClientMessage clientMessage,
                                         Node node,
                                         Connection connection)  | 
ExecutorServiceSubmitToPartitionMessageTask(ClientMessage clientMessage,
                                           Node node,
                                           Connection connection)  | 
| 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)  | 
| Constructor and Description | 
|---|
LockForceUnlockMessageTask(ClientMessage clientMessage,
                          Node node,
                          Connection connection)  | 
LockGetLockCountMessageTask(ClientMessage clientMessage,
                           Node node,
                           Connection connection)  | 
LockGetRemainingLeaseTimeMessageTask(ClientMessage clientMessage,
                                    Node node,
                                    Connection connection)  | 
LockIsLockedByCurrentThreadMessageTask(ClientMessage clientMessage,
                                      Node node,
                                      Connection connection)  | 
LockIsLockedMessageTask(ClientMessage clientMessage,
                       Node node,
                       Connection connection)  | 
LockLockMessageTask(ClientMessage clientMessage,
                   Node node,
                   Connection connection)  | 
LockTryLockMessageTask(ClientMessage clientMessage,
                      Node node,
                      Connection connection)  | 
LockUnlockMessageTask(ClientMessage clientMessage,
                     Node node,
                     Connection connection)  | 
| Constructor and Description | 
|---|
AbstractMapReduceTask(ClientMessage clientMessage,
                     Node node,
                     Connection connection)  | 
MapReduceCancelMessageTask(ClientMessage clientMessage,
                          Node node,
                          Connection connection)  | 
MapReduceForCustomMessageTask(ClientMessage clientMessage,
                             Node node,
                             Connection connection)  | 
MapReduceForListMessageTask(ClientMessage clientMessage,
                           Node node,
                           Connection connection)  | 
MapReduceForMapMessageTask(ClientMessage clientMessage,
                          Node node,
                          Connection connection)  | 
MapReduceForMultiMapMessageTask(ClientMessage clientMessage,
                               Node node,
                               Connection connection)  | 
MapReduceForSetMessageTask(ClientMessage clientMessage,
                          Node node,
                          Connection connection)  | 
MapReduceJobProcessInformationMessageTask(ClientMessage clientMessage,
                                         Node node,
                                         Connection connection)  | 
| 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)  | 
| Constructor and Description | 
|---|
SemaphoreAcquireMessageTask(ClientMessage clientMessage,
                           Node node,
                           Connection connection)  | 
SemaphoreAvailablePermitsMessageTasks(ClientMessage clientMessage,
                                     Node node,
                                     Connection connection)  | 
SemaphoreDrainPermitsMessageTask(ClientMessage clientMessage,
                                Node node,
                                Connection connection)  | 
SemaphoreIncreasePermitsMessageTask(ClientMessage clientMessage,
                                   Node node,
                                   Connection connection)  | 
SemaphoreInitMessageTask(ClientMessage clientMessage,
                        Node node,
                        Connection connection)  | 
SemaphoreReducePermitsMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection)  | 
SemaphoreReleaseMessageTask(ClientMessage clientMessage,
                           Node node,
                           Connection connection)  | 
SemaphoreTryAcquireMessageTask(ClientMessage clientMessage,
                              Node node,
                              Connection connection)  | 
| Constructor and Description | 
|---|
TopicAddMessageListenerMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection)  | 
TopicPublishMessageTask(ClientMessage clientMessage,
                       Node node,
                       Connection connection)  | 
TopicRemoveMessageListenerMessageTask(ClientMessage clientMessage,
                                     Node node,
                                     Connection connection)  | 
| Constructor and Description | 
|---|
TransactionalListAddMessageTask(ClientMessage clientMessage,
                               Node node,
                               Connection connection)  | 
TransactionalListRemoveMessageTask(ClientMessage clientMessage,
                                  Node node,
                                  Connection connection)  | 
TransactionalListSizeMessageTask(ClientMessage clientMessage,
                                Node node,
                                Connection connection)  | 
| 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)  | 
| 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)  | 
| Constructor and Description | 
|---|
TransactionalSetAddMessageTask(ClientMessage clientMessage,
                              Node node,
                              Connection connection)  | 
TransactionalSetRemoveMessageTask(ClientMessage clientMessage,
                                 Node node,
                                 Connection connection)  | 
TransactionalSetSizeMessageTask(ClientMessage clientMessage,
                               Node node,
                               Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClientMessageHandler.handle(ClientMessage message,
      Connection connection)
Received message to be processed 
 | 
| Constructor and Description | 
|---|
ClientMessageDecoder(Connection connection,
                    ClientMessageHandler messageHandler)  | 
| Modifier and Type | Method and Description | 
|---|---|
static ClientMessage | 
ClientTransactionUtil.invoke(ClientMessage request,
      String objectName,
      HazelcastClientInstanceImpl client,
      Connection connection)
Handles the invocation exception for transactions so that users will not see internal exceptions. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ProxyManager.createDistributedObjectsOnCluster(Connection ownerConnection)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClientUserCodeDeploymentService.deploy(HazelcastClientInstanceImpl client,
      Connection ownerConnection)  | 
void | 
ConnectionHeartbeatListener.heartbeatResumed(Connection connection)
This event will be fired when the heartbeat is resumed for a connection to a member. 
 | 
void | 
ConnectionHeartbeatListener.heartbeatStopped(Connection connection)
This event will be fired when no heartbeat response is received for
  
ClientProperty.HEARTBEAT_TIMEOUT milliseconds from the member. | 
void | 
ClientClusterServiceImpl.listenMembershipEvents(Connection ownerConnection)  | 
void | 
ClientPartitionServiceImpl.listenPartitionTable(Connection ownerConnection)  | 
| Constructor and Description | 
|---|
ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                Connection connection)
Create an invocation that will be executed on given  
connection. | 
ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                String objectName,
                int partitionId,
                Address address,
                Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
ClientEventRegistration.getSubscriber()
This is used when removing the listener. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Map<ClientRegistrationKey,Map<Connection,ClientEventRegistration>> | 
SmartClientListenerService.getRegistrations()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
NonSmartClientListenerService.connectionAdded(Connection connection)  | 
void | 
SmartClientListenerService.connectionAdded(Connection connection)  | 
void | 
NonSmartClientListenerService.connectionRemoved(Connection connection)  | 
void | 
SmartClientListenerService.connectionRemoved(Connection connection)  | 
void | 
AbstractClientListenerService.handleClientMessage(ClientMessage clientMessage,
                   Connection connection)  | 
void | 
SmartClientListenerService.heartbeatResumed(Connection connection)  | 
void | 
SmartClientListenerService.heartbeatStopped(Connection connection)  | 
| Constructor and Description | 
|---|
ClientEventRegistration(String serverRegistrationId,
                       long callId,
                       Connection subscriber,
                       ListenerMessageCodec codec)  | 
| Constructor and Description | 
|---|
NewIdBatchMessageTask(ClientMessage clientMessage,
                     Node node,
                     Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClusterJoinManager.answerWhoisMasterQuestion(JoinMessage joinMessage,
                         Connection connection)
Respond to a  
WhoisMasterOp. | 
void | 
ClusterServiceImpl.connectionAdded(Connection connection)  | 
void | 
ClusterServiceImpl.connectionRemoved(Connection connection)  | 
void | 
ClusterJoinManager.handleJoinRequest(JoinRequest joinRequest,
                 Connection connection)
Handle a  
JoinRequestOp. | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
Packet.getConn()
Gets the Connection this Packet was send with. 
 | 
Connection | 
ConnectionManager.getConnection(Address address)
Gets the connection for a given address. 
 | 
Connection | 
ConnectionManager.getOrConnect(Address address)
Gets the existing connection for a given address or connects. 
 | 
Connection | 
ConnectionManager.getOrConnect(Address address,
            boolean silent)
Gets the existing connection for a given address. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ConnectionListener.connectionAdded(Connection connection)  | 
void | 
ConnectionListener.connectionRemoved(Connection connection)  | 
void | 
ConnectionManager.onConnectionClose(Connection connection)
Deals with cleaning up a closed connection. 
 | 
boolean | 
ConnectionManager.registerConnection(Address address,
                  Connection connection)  | 
Packet | 
Packet.setConn(Connection conn)
Sets the Connection this Packet is send with. 
 | 
boolean | 
ConnectionManager.transmit(Packet packet,
        Connection connection)
Transmits a packet to a certain connection. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TcpIpConnection
The Tcp/Ip implementation of the  
Connection. | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
TcpIpConnectionManager.getConnection(Address address)  | 
Connection | 
TcpIpConnectionManager.getOrConnect(Address address)  | 
Connection | 
TcpIpConnectionManager.getOrConnect(Address address,
            boolean silent)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TcpIpConnectionManager.onConnectionClose(Connection connection)
Deals with cleaning up a closed connection. 
 | 
boolean | 
TcpIpConnectionManager.registerConnection(Address remoteEndPoint,
                  Connection connection)  | 
boolean | 
TcpIpConnectionManager.transmit(Packet packet,
        Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
Connection | 
Operation.getConnection()  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
OperationAccessor.setConnection(Operation op,
             Connection connection)  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
OutboundOperationHandler.send(Operation op,
    Connection connection)  | 
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.