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

Methods

Modifier and Type	Method and Description
void	addConnectionHeartbeatListener(ConnectionHeartbeatListener connectionHeartbeatListener)
void	destroyConnection(Connection connection, String reason, Throwable cause) Destroys the connection Clears related resources of given connection.
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)

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

destroyConnection

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

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.

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

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)