com.hazelcast.client.impl.connection.nio

Class ClusterConnectorServiceImpl

java.lang.Object

com.hazelcast.client.impl.connection.nio.ClusterConnectorServiceImpl

All Implemented Interfaces:

ClusterConnectorService, ConnectionListener

public class ClusterConnectorServiceImpl
extends Object
implements ClusterConnectorService, ConnectionListener

selects a connection to listen cluster state(membership and partition listener), Keeps those listeners available when connection disconnected by picking a new connection. Changing cluster is also handled in this class(Blue/green feature)

Constructor Summary

Constructors

Constructor and Description
ClusterConnectorServiceImpl(HazelcastClientInstanceImpl client, ClientConnectionManagerImpl connectionManager, ClientConnectionStrategy connectionStrategy, ClientDiscoveryService discoveryService)

Method Summary

Modifier and Type	Method and Description
void	connectionAdded(Connection connection)
void	connectionRemoved(Connection connection)
void	connectToCluster()
Future<Void>	connectToClusterAsync()
ClientConnection	getClusterConnection()
boolean	mainConnectionExists()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterConnectorServiceImpl

public ClusterConnectorServiceImpl(HazelcastClientInstanceImpl client,
                                   ClientConnectionManagerImpl connectionManager,
                                   ClientConnectionStrategy connectionStrategy,
                                   ClientDiscoveryService discoveryService)

Method Detail

connectToCluster

public void connectToCluster()

Specified by:

connectToCluster in interface ClusterConnectorService

mainConnectionExists

public boolean mainConnectionExists()

Specified by:

mainConnectionExists in interface ClusterConnectorService

getClusterConnection

public ClientConnection getClusterConnection()

Specified by:

getClusterConnection in interface ClusterConnectorService

Returns:

client connection that is used to listen cluster at the moment

connectToClusterAsync

public Future<Void> connectToClusterAsync()

Specified by:

connectToClusterAsync in interface ClusterConnectorService

shutdown

public void shutdown()

Specified by:

shutdown in interface ClusterConnectorService

connectionAdded

public void connectionAdded(Connection connection)

Specified by:

connectionAdded in interface ConnectionListener

connectionRemoved

public void connectionRemoved(Connection connection)

Specified by:

connectionRemoved in interface ConnectionListener