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.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.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.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.
|
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.
|
void |
ClientEngine.handleClientMessage(ClientMessage message,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
Connection |
ClientConnectionManager.getActiveConnection(Address address) |
Connection |
ClientConnectionManager.getOrConnect(Address address) |
Connection |
ClientConnectionManager.getOrTriggerConnect(Address address) |
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) |
Modifier and Type | Method and Description |
---|---|
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.handleClientMessage(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 |
---|
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 |
---|---|
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 |
ClientInvocationService.handleClientMessage(ClientMessage message,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
ClientUserCodeDeploymentService.deploy(HazelcastClientInstanceImpl client,
Connection ownerConnection) |
void |
AbstractClientInvocationService.handleClientMessage(ClientMessage message,
Connection connection) |
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) |
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) |
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) |
Constructor and Description |
---|
MessageHandlerImpl(Connection connection,
ClientEngine clientEngine) |
Modifier and Type | Method and Description |
---|---|
Connection |
Operation.getConnection() |
Modifier and Type | Method and Description |
---|---|
static void |
OperationAccessor.setConnection(Operation op,
Connection connection) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.