| 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.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.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.internal.cluster.impl | This package contains the implementation of the cluster functionality. | 
| com.hazelcast.internal.networking | Contains the socket connection functionality. | 
| com.hazelcast.nio | This package contains classes related to New IO | 
| com.hazelcast.nio.tcp | Contains functionality for the TCP/IP Networking between cluster members 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. | 
| Modifier and Type | Method and Description | 
|---|---|
| Connection | ClientEndpointManager. findLiveConnectionFor(String clientUuid) | 
| 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. getConnection(Address address) | 
| Connection | ClientConnectionManager. getOrConnect(Address address,
            boolean asOwner) | 
| Connection | ClientConnectionManager. getOrTriggerConnect(Address address,
                   boolean asOwner) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ClientConnectionManager. handleClientMessage(ClientMessage message,
                   Connection connection)Handles incoming network package | 
| void | ClientConnectionManager. onClose(Connection connection) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ClientConnectionClient implementation of  Connection. | 
| Modifier and Type | Method and Description | 
|---|---|
| Connection | ClientConnectionManagerImpl. getOrConnect(Address address,
            boolean asOwner) | 
| Connection | ClientConnectionManagerImpl. getOrTriggerConnect(Address target,
                   boolean asOwner) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ClientConnectionManagerImpl. handleClientMessage(ClientMessage message,
                   Connection connection) | 
| void | ClientConnectionManagerImpl. onClose(Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| Connection | ClientEndpointManagerImpl. findLiveConnectionFor(String clientUuid) | 
| Connection | ClientEndpointImpl. getConnection() | 
| Modifier and Type | Method and Description | 
|---|---|
| MessageTask | CompositeMessageTaskFactory. create(ClientMessage clientMessage,
      Connection connection) | 
| ClientEndpoint | ClientEndpointManagerImpl. getEndpoint(Connection connection) | 
| void | ClientEngineImpl. handleClientMessage(ClientMessage clientMessage,
                   Connection connection) | 
| Constructor and Description | 
|---|
| ClientEndpointImpl(ClientEngineImpl clientEngine,
                  Connection conn) | 
| Modifier and Type | Method and Description | 
|---|---|
| MessageTask | MessageTaskFactory. create(ClientMessage clientMessage,
      Connection connection) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected Connection | AbstractMessageTask. connection | 
| Modifier and Type | Method and Description | 
|---|---|
| protected Connection | PingMessageTask. findSendConnection() | 
| protected Connection | AbstractMessageTask. findSendConnection() | 
| 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 | 
|---|
| 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) | 
| 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 | ClientInvocationService. handleClientMessage(ClientMessage message,
                   Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ClusterListenerSupport. connectionAdded(Connection connection) | 
| void | ClusterListenerSupport. connectionRemoved(Connection connection) | 
| void | ConnectionHeartbeatListener. heartbeatResumed(Connection connection)This event will be fired when the heartbeat is resumed for a connection to a member. | 
| void | ClusterListenerSupport. heartbeatResumed(Connection connection) | 
| void | ConnectionHeartbeatListener. heartbeatStopped(Connection connection)This event will be fired when no heartbeat response is received for
  ClientProperty.HEARTBEAT_TIMEOUTmilliseconds from the member. | 
| void | ClusterListenerSupport. heartbeatStopped(Connection connection) | 
| Constructor and Description | 
|---|
| ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                Connection connection) | 
| ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                int partitionId,
                Address address,
                Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ClientListenerServiceImpl. handleClientMessage(ClientMessage clientMessage,
                   Connection connection) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ClusterJoinManager. answerMasterQuestion(JoinMessage joinMessage,
                    Connection connection)Respond to a  MasterDiscoveryOperation. | 
| void | ClusterServiceImpl. connectionAdded(Connection connection) | 
| void | ClusterServiceImpl. connectionRemoved(Connection connection) | 
| void | ClusterJoinManager. handleJoinRequest(JoinRequest joinRequest,
                 Connection connection)Handle a  JoinRequestOperation:
 
     If this node is not master, reply with aSetMasterOperationto let the joining node know the current
     master
     Otherwise, if no other join is in progress, execute theJoinRequest | 
| Modifier and Type | Interface and Description | 
|---|---|
| interface  | SocketReaderInitializer<C extends Connection> | 
| interface  | SocketWriterInitializer<C extends Connection> | 
| Modifier and Type | Interface and Description | 
|---|---|
| interface  | SocketConnection | 
| 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 | NodeIOService. handleClientMessage(ClientMessage cm,
                   Connection connection) | 
| void | IOService. handleClientMessage(ClientMessage cm,
                   Connection 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  | TcpIpConnectionThe 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 | 
|---|---|
| boolean | TcpIpConnectionManager. registerConnection(Address remoteEndPoint,
                  Connection connection) | 
| boolean | TcpIpConnectionManager. transmit(Packet packet,
        Connection connection) | 
| Constructor and Description | 
|---|
| ClientReadHandler(SwCounter messageCounter,
                 Connection connection,
                 IOService ioService) | 
| Modifier and Type | Method and Description | 
|---|---|
| Connection | Operation. getConnection() | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | OperationAccessor. setConnection(Operation op,
             Connection connection) | 
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.