com.hazelcast.client.connection.nio

Class ClientConnectionManagerImpl

java.lang.Object

com.hazelcast.client.connection.nio.ClientConnectionManagerImpl

All Implemented Interfaces:

ClientConnectionManager, ConnectionListenable

public class ClientConnectionManagerImpl
extends Object
implements ClientConnectionManager

Implementation of ClientConnectionManager.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	alive
protected AtomicInteger	connectionIdGen

Constructor Summary

Constructors

Constructor and Description
ClientConnectionManagerImpl(HazelcastClientInstanceImpl client, AddressTranslator addressTranslator, Collection<AddressProvider> addressProviders)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener connectionListener) Registers a ConnectionListener.
void	connectToCluster()
Future<Void>	connectToClusterAsync()
protected ClientConnection	createSocketConnection(Address remoteAddress)
Connection	getActiveConnection(Address target)
Collection<ClientConnection>	getActiveConnections()
ClientConnectionStrategy	getConnectionStrategy()
Credentials	getLastCredentials()
NioNetworking	getNetworking()
Connection	getOrConnect(Address address)
Connection	getOrTriggerConnect(Address target, boolean acquiresResources)
ClientConnection	getOwnerConnection()
Address	getOwnerConnectionAddress()
ClientPrincipal	getPrincipal()
protected NioNetworking	initNetworking(HazelcastClientInstanceImpl client)
boolean	isAlive() Check if client connection manager is alive.
void	shutdown()
void	start(ClientContext clientContext)
protected void	startNetworking()
protected void	stopNetworking()

Methods inherited from class java.lang.Object

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

Field Detail

connectionIdGen

protected final AtomicInteger connectionIdGen

alive

protected volatile boolean alive

Constructor Detail

ClientConnectionManagerImpl

public ClientConnectionManagerImpl(HazelcastClientInstanceImpl client,
                                   AddressTranslator addressTranslator,
                                   Collection<AddressProvider> addressProviders)

Method Detail

getNetworking

public NioNetworking getNetworking()

initNetworking

protected NioNetworking initNetworking(HazelcastClientInstanceImpl client)

getConnectionStrategy

public ClientConnectionStrategy getConnectionStrategy()

getActiveConnections

public Collection<ClientConnection> getActiveConnections()

Specified by:

getActiveConnections in interface ClientConnectionManager

isAlive

public boolean isAlive()

Description copied from interface: ClientConnectionManager

Check if client connection manager is alive. ClientConnectionManager is not alive only when client is closing.

Specified by:

isAlive in interface ClientConnectionManager

Returns:

true if alive, false otherwise.

start

public void start(ClientContext clientContext)

startNetworking

protected void startNetworking()

shutdown

public void shutdown()

getPrincipal

public ClientPrincipal getPrincipal()

Specified by:

getPrincipal in interface ClientConnectionManager

stopNetworking

protected void stopNetworking()

getActiveConnection

public Connection getActiveConnection(Address target)

Specified by:

getActiveConnection in interface ClientConnectionManager

Parameters:

target - to be connected

Returns:

connection if available, null otherwise

getOrConnect

public Connection getOrConnect(Address address)
                        throws IOException

Specified by:

getOrConnect in interface ClientConnectionManager

Parameters:

address - to be connected

Returns:

associated connection if available, creates new connection otherwise

Throws:

IOException - if connection is not established

getOrTriggerConnect

public Connection getOrTriggerConnect(Address target,
                                      boolean acquiresResources)
                               throws IOException

Specified by:

getOrTriggerConnect in interface ClientConnectionManager

Parameters:

target - to be connected

Returns:

associated connection if available, returns null and triggers new connection creation otherwise

Throws:

IOException - if connection is not able to triggered

getOwnerConnectionAddress

public Address getOwnerConnectionAddress()

Specified by:

getOwnerConnectionAddress in interface ClientConnectionManager

getOwnerConnection

public ClientConnection getOwnerConnection()

Specified by:

getOwnerConnection in interface ClientConnectionManager

createSocketConnection

protected ClientConnection createSocketConnection(Address remoteAddress)
                                           throws IOException

Throws:

IOException

addConnectionListener

public void addConnectionListener(ConnectionListener connectionListener)

Description copied from interface: ConnectionListenable

Registers a ConnectionListener. If the same listener is registered multiple times, it will be notified multiple times.

Specified by:

addConnectionListener in interface ConnectionListenable

Parameters:

connectionListener - the ConnectionListener to add.

getLastCredentials

public Credentials getLastCredentials()

connectToCluster

public void connectToCluster()

Specified by:

connectToCluster in interface ClientConnectionManager

connectToClusterAsync

public Future<Void> connectToClusterAsync()

Specified by:

connectToClusterAsync in interface ClientConnectionManager