com.hazelcast.client.connection.nio

Class ClientConnectionManagerImpl

java.lang.Object

com.hazelcast.client.connection.nio.ClientConnectionManagerImpl

All Implemented Interfaces:

ClientConnectionManager

public class ClientConnectionManagerImpl
extends Object
implements 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)

Method Summary

Methods

Modifier and Type	Method and Description
void	addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)
void	addConnectionListener(ConnectionListener connectionListener)
protected ClientConnection	createSocketConnection(Address address)
void	destroyConnection(Connection connection) Destroys the connection Clears related resources of given connection.
ClientConnection	getConnection(Address target)
ClientConnection	getOrConnect(Address target, Authenticator authenticator)
ClientConnection	getOrTriggerConnect(Address target, Authenticator authenticator)
void	handleClientMessage(ClientMessage message, Connection connection) Handles incoming network package
protected void	initializeSelectors(HazelcastClientInstanceImpl client)
boolean	isAlive() Check if client connection manager is alive.
void	shutdown() Shutdown clientConnectionManager
protected void	shutdownSelectors()
void	start() Start clientConnectionManager
protected void	startSelectors()

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)

Method Detail

initializeSelectors

protected void initializeSelectors(HazelcastClientInstanceImpl client)

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()

Description copied from interface: ClientConnectionManager

Start clientConnectionManager

Specified by:

start in interface ClientConnectionManager

startSelectors

protected void startSelectors()

shutdown

public void shutdown()

Description copied from interface: ClientConnectionManager

Shutdown clientConnectionManager

Specified by:

shutdown in interface ClientConnectionManager

shutdownSelectors

protected void shutdownSelectors()

getConnection

public ClientConnection getConnection(Address target)

Specified by:

getConnection in interface ClientConnectionManager

Parameters:

target - to be connected

Returns:

connection if available, null otherwise

getOrConnect

public ClientConnection getOrConnect(Address target,
                            Authenticator authenticator)
                              throws IOException

Specified by:

getOrConnect in interface ClientConnectionManager

Parameters:

target - to be connected

authenticator - Authenticator implementation to send appropriate Authentication Request after connection

Returns:

associated connection if available, creates new connection otherwise

Throws:

IOException - if connection is not established

getOrTriggerConnect

public ClientConnection getOrTriggerConnect(Address target,
                                   Authenticator authenticator)
                                     throws IOException

Specified by:

getOrTriggerConnect in interface ClientConnectionManager

Parameters:

target - to be connected

authenticator - Authenticator implementation to send appropriate Authentication Request after connection

Returns:

associated connection if available, triggers new connection creation otherwise

Throws:

IOException - if connection is not available at the time of call

createSocketConnection

protected ClientConnection createSocketConnection(Address address)
                                           throws IOException

Throws:

IOException

destroyConnection

public void destroyConnection(Connection connection)

Description copied from interface: ClientConnectionManager

Destroys the connection Clears related resources of given connection. ConnectionListener.connectionRemoved is called on registered listeners.

If connection is already destroyed before calling this then does nothing.

Specified by:

destroyConnection in interface ClientConnectionManager

Parameters:

connection - to be closed

handleClientMessage

public void handleClientMessage(ClientMessage message,
                       Connection connection)

Description copied from interface: ClientConnectionManager

Handles incoming network package

Specified by:

handleClientMessage in interface ClientConnectionManager

Parameters:

message - to be processed

connection - that client message come from

addConnectionListener

public void addConnectionListener(ConnectionListener connectionListener)

Specified by:

addConnectionListener in interface ClientConnectionManager

addConnectionHeartbeatListener

public void addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)

Specified by:

addConnectionHeartbeatListener in interface ClientConnectionManager