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.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.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 Service Provider Interface
such as ClientProxy , ClientClusterService
|
com.hazelcast.client.spi.impl |
Provides util classes for com.hazelcast.client
|
com.hazelcast.client.spi.impl.listener | |
com.hazelcast.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 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 |
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.destroyConnection(Connection connection,
String reason,
Throwable cause)
Destroys the connection
Clears related resources of given connection.
|
void |
ClientConnectionManager.handleClientMessage(ClientMessage message,
Connection connection)
Handles incoming network package
|
Modifier and Type | Class and Description |
---|---|
class |
ClientConnection
Client 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.destroyConnection(Connection connection,
String reason,
Throwable cause) |
void |
ClientConnectionManagerImpl.handleClientMessage(ClientMessage message,
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.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 |
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
com.hazelcast.client.spi.properties.ClientProperty.HEARTBEAT_TIMEOUT milliseconds 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 |
ClientNonSmartListenerService.connectionAdded(Connection connection) |
void |
ClientNonSmartListenerService.connectionRemoved(Connection connection) |
void |
ClientListenerServiceImpl.handleClientMessage(ClientMessage clientMessage,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterJoinManager.answerMasterQuestion(JoinMessage joinMessage,
Connection connection) |
void |
ClusterServiceImpl.connectionAdded(Connection connection) |
void |
ClusterServiceImpl.connectionRemoved(Connection connection) |
void |
ClusterJoinManager.handleJoinRequest(JoinRequest joinRequest,
Connection connection) |
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) |
void |
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 |
---|---|
boolean |
TcpIpConnectionManager.registerConnection(Address remoteEndPoint,
Connection connection) |
boolean |
TcpIpConnectionManager.transmit(Packet packet,
Connection connection) |
Constructor and Description |
---|
ClientReadHandler(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.