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

Modifier and Type	Method and Description
void	addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)
void	addConnectionListener(ConnectionListener connectionListener) Registers a ConnectionListener.
protected ClientConnection	createSocketConnection(Address address)
Collection<ClientConnection>	getActiveConnections()
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	initIOThreads(HazelcastClientInstanceImpl client)
boolean	isAlive() Check if client connection manager is alive.
void	shutdown() Shutdown clientConnectionManager
protected void	shutdownIOThreads()
void	start() Start clientConnectionManager
protected void	startIOThreads()

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

initIOThreads

protected void initIOThreads(HazelcastClientInstanceImpl client)

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

Description copied from interface: ClientConnectionManager

Start clientConnectionManager

Specified by:

start in interface ClientConnectionManager

startIOThreads

protected void startIOThreads()

shutdown

public void shutdown()

Description copied from interface: ClientConnectionManager

Shutdown clientConnectionManager

Specified by:

shutdown in interface ClientConnectionManager

shutdownIOThreads

protected void shutdownIOThreads()

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)
                               throws IOException

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

Throws:

IOException - if connection is not able to triggered

createSocketConnection

protected ClientConnection createSocketConnection(Address address)
                                           throws IOException

Throws:

IOException

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