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)

Method Summary

Methods

Modifier and Type	Method and Description
void	addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)
void	addConnectionListener(ConnectionListener connectionListener) Registers a ConnectionListener.
protected ClientConnection	createSocketConnection(Address address)
void	destroyConnection(Connection connection, String reason, Throwable cause) Destroys the connection Clears related resources of given connection.
ClientConnection	getConnection(Address target)
Connection	getOrConnect(Address address, boolean asOwner)
Connection	getOrTriggerConnect(Address target, boolean asOwner)
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 Connection getOrConnect(Address address,
                      boolean asOwner)
                        throws IOException

Specified by:

getOrConnect in interface ClientConnectionManager

Parameters:

address - to be connected

asOwner - true if connection should be authenticated as owner, false otherwise

Returns:

associated connection if available, creates new connection otherwise

Throws:

IOException - if connection is not established

getOrTriggerConnect

public Connection getOrTriggerConnect(Address target,
                             boolean asOwner)

Specified by:

getOrTriggerConnect in interface ClientConnectionManager

Parameters:

target - to be connected

asOwner - true if connection should be authenticated as owner, false otherwise

Returns:

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

createSocketConnection

protected ClientConnection createSocketConnection(Address address)
                                           throws IOException

Throws:

IOException

destroyConnection

public void destroyConnection(Connection connection,
                     String reason,
                     Throwable cause)

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

reason - the reason of closing this exception. Can be null if no reason is given.

cause - exception that cause connection to be closed, null if closed explicitly

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)

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.

addConnectionHeartbeatListener

public void addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)

Specified by:

addConnectionHeartbeatListener in interface ClientConnectionManager