com.hazelcast.client.connection

Interface ClientConnectionManager

All Superinterfaces:

ConnectionListenable

public interface ClientConnectionManager
extends ConnectionListenable

Responsible for managing ClientConnection objects.

Method Summary

Modifier and Type	Method and Description
void	connectToCluster()
Future<Void>	connectToClusterAsync()
Connection	getActiveConnection(Address address)
Collection<com.hazelcast.client.connection.nio.ClientConnection>	getActiveConnections()
Connection	getOrConnect(Address address)
Connection	getOrTriggerConnect(Address address, boolean acquiresResource)
com.hazelcast.client.connection.nio.ClientConnection	getOwnerConnection()
Address	getOwnerConnectionAddress()
com.hazelcast.client.impl.client.ClientPrincipal	getPrincipal()
boolean	isAlive() Check if client connection manager is alive.

Methods inherited from interface com.hazelcast.nio.ConnectionListenable

addConnectionListener

Method Detail

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.

getActiveConnection

Connection getActiveConnection(Address address)

Parameters:

address - to be connected

Returns:

connection if available, null otherwise

getOrConnect

Connection getOrConnect(Address address)
                 throws IOException

Parameters:

address - to be connected

Returns:

associated connection if available, creates new connection otherwise

Throws:

IOException - if connection is not established

getOrTriggerConnect

Connection getOrTriggerConnect(Address address,
                               boolean acquiresResource)
                        throws IOException

Parameters:

address - to be connected

Returns:

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

Throws:

IOException - if connection is not able to triggered

getActiveConnections

Collection<com.hazelcast.client.connection.nio.ClientConnection> getActiveConnections()

getOwnerConnectionAddress

Address getOwnerConnectionAddress()

getPrincipal

com.hazelcast.client.impl.client.ClientPrincipal getPrincipal()

getOwnerConnection

com.hazelcast.client.connection.nio.ClientConnection getOwnerConnection()

connectToCluster

void connectToCluster()

connectToClusterAsync

Future<Void> connectToClusterAsync()