com.hazelcast.client.connection

Interface ClientConnectionManager

All Superinterfaces:

ConnectionListenable

All Known Implementing Classes:

ClientConnectionManagerImpl

public interface ClientConnectionManager
extends ConnectionListenable

Responsible for managing ClientConnection objects.

Method Summary

Modifier and Type	Method and Description
void	addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)
Collection<ClientConnection>	getActiveConnections()
Connection	getConnection(Address address)
Connection	getOrConnect(Address address, boolean asOwner)
Connection	getOrTriggerConnect(Address address, boolean asOwner)
void	handleClientMessage(ClientMessage message, Connection connection) Handles incoming network package
boolean	isAlive() Check if client connection manager is alive.
void	shutdown() Shutdown clientConnectionManager
void	start() Start clientConnectionManager

Methods inherited from interface com.hazelcast.nio.ConnectionListenable

addConnectionListener

Method Detail

shutdown

void shutdown()

Shutdown clientConnectionManager

isAlive

boolean isAlive()

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

Returns:

true if alive, false otherwise.

start

void start()

Start clientConnectionManager

getConnection

Connection getConnection(Address address)

Parameters:

address - to be connected

Returns:

connection if available, null otherwise

getOrConnect

Connection getOrConnect(Address address,
                        boolean asOwner)
                 throws IOException

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

Connection getOrTriggerConnect(Address address,
                               boolean asOwner)
                        throws IOException

Parameters:

address - 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

handleClientMessage

void handleClientMessage(ClientMessage message,
                         Connection connection)

Handles incoming network package

Parameters:

message - to be processed

connection - that client message come from

addConnectionHeartbeatListener

void addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)

getActiveConnections

Collection<ClientConnection> getActiveConnections()