com.hazelcast.client.connection.nio

Class DefaultClientConnectionStrategy

java.lang.Object

com.hazelcast.client.connection.ClientConnectionStrategy

com.hazelcast.client.connection.nio.DefaultClientConnectionStrategy

public class DefaultClientConnectionStrategy
extends ClientConnectionStrategy

Default client connection strategy supporting async client start, reconnection modes and disabling reconnection.

Field Summary

Fields inherited from class com.hazelcast.client.connection.ClientConnectionStrategy

clientConnectionStrategyConfig, clientContext, logger

Constructor Summary

Constructors

Constructor and Description
DefaultClientConnectionStrategy()

Method Summary

Modifier and Type	Method and Description
void	beforeGetConnection(Address target) The purpose of this method is to validate a connection request by target, and exit the blocking invocation.
void	beforeOpenConnection(Address target) If a new connection is required to open by ClientConnectionManager, this method will be called.
void	onConnect(ClientConnection connection) If the ClientConnectionManager opens a new connection to a member, this method will be called with the connection parameter
void	onConnectToCluster() If a cluster connection is established, this method will be called.
void	onDisconnect(ClientConnection connection) If a connection is disconnected, this method will be called with the connection parameter
void	onDisconnectFromCluster() If the cluster connection is lost for any reason, this method will be called.
void	onHeartbeatResumed(ClientConnection connection) The ClientConnectionManager will inform this method that the provided connection's heartbeat resumed
void	onHeartbeatStopped(ClientConnection connection) The ClientConnectionManager will inform this method that the provided connection's heartbeat stopped
void	shutdown() The ClientConnectionManager will call this method as a last step of its shutdown.
void	start() Called after ClientConnectionManager started.

Methods inherited from class com.hazelcast.client.connection.ClientConnectionStrategy

init

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultClientConnectionStrategy

public DefaultClientConnectionStrategy()

Method Detail

start

public void start()

Description copied from class: ClientConnectionStrategy

Called after ClientConnectionManager started. Connecting to cluster can be triggered from this method using one of ClientConnectionManager.connectToCluster() or ClientConnectionManager.connectToClusterAsync()

Specified by:

start in class ClientConnectionStrategy

beforeGetConnection

public void beforeGetConnection(Address target)

Description copied from class: ClientConnectionStrategy

The purpose of this method is to validate a connection request by target, and exit the blocking invocation. For all connection requests on ClientConnectionManager this method will be called. The build in retry mechanism can be stopped by throwing an instance of non retryable exceptions; IOException, HazelcastInstanceNotActiveException or RetryableException The thrown exception will be received on the blocking user. Any blocking invocation will exit by that exception.

Specified by:

beforeGetConnection in class ClientConnectionStrategy

Parameters:

target - address of the requested connection

beforeOpenConnection

public void beforeOpenConnection(Address target)

Description copied from class: ClientConnectionStrategy

If a new connection is required to open by ClientConnectionManager, this method will be called. This request can be rejected by throwing an instance of non retryable exceptions; IOException, HazelcastInstanceNotActiveException or RetryableException

Specified by:

beforeOpenConnection in class ClientConnectionStrategy

Parameters:

target - address of the requested connection

onConnectToCluster

public void onConnectToCluster()

Description copied from class: ClientConnectionStrategy

If a cluster connection is established, this method will be called. if an exception is thrown, the already established connection will be closed.

Specified by:

onConnectToCluster in class ClientConnectionStrategy

onDisconnectFromCluster

public void onDisconnectFromCluster()

Description copied from class: ClientConnectionStrategy

If the cluster connection is lost for any reason, this method will be called.

Specified by:

onDisconnectFromCluster in class ClientConnectionStrategy

onConnect

public void onConnect(ClientConnection connection)

Description copied from class: ClientConnectionStrategy

If the ClientConnectionManager opens a new connection to a member, this method will be called with the connection parameter

Specified by:

onConnect in class ClientConnectionStrategy

Parameters:

connection - the new established connection

onDisconnect

public void onDisconnect(ClientConnection connection)

Description copied from class: ClientConnectionStrategy

If a connection is disconnected, this method will be called with the connection parameter

Specified by:

onDisconnect in class ClientConnectionStrategy

Parameters:

connection - the closed connection

onHeartbeatStopped

public void onHeartbeatStopped(ClientConnection connection)

Description copied from class: ClientConnectionStrategy

The ClientConnectionManager will inform this method that the provided connection's heartbeat stopped

Specified by:

onHeartbeatStopped in class ClientConnectionStrategy

Parameters:

connection - the connection that heartbeat failed

onHeartbeatResumed

public void onHeartbeatResumed(ClientConnection connection)

Description copied from class: ClientConnectionStrategy

The ClientConnectionManager will inform this method that the provided connection's heartbeat resumed

Specified by:

onHeartbeatResumed in class ClientConnectionStrategy

Parameters:

connection - the connection that heartbeat resumed

shutdown

public void shutdown()

Description copied from class: ClientConnectionStrategy

The ClientConnectionManager will call this method as a last step of its shutdown.

Specified by:

shutdown in class ClientConnectionStrategy