com.hazelcast.client.connection.nio

Class ClientConnectionManagerImpl

java.lang.Object

com.hazelcast.client.connection.nio.ClientConnectionManagerImpl

All Implemented Interfaces:

ClientConnectionManager

public class ClientConnectionManagerImpl
extends Object
implements ClientConnectionManager

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ClientConnectionManagerImpl.ManagerAuthenticator

Field Summary

Fields

Modifier and Type	Field and Description
static int	BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
ClientConnectionManagerImpl(HazelcastClient client, LoadBalancer loadBalancer)

Method Summary

Modifier and Type	Method and Description
void	destroyConnection(ClientConnection clientConnection)
ClientPrincipal	getPrincipal()
SerializationContext	getSerializationContext()
SerializationService	getSerializationService()
void	handlePacket(ClientPacket packet)
boolean	isLive()
void	markOwnerAddressAsClosed()
int	newCallId()
ClientConnection	ownerConnection(Address address)
boolean	removeEventHandler(Integer callId)
Object	sendAndReceive(ClientRequest request, ClientConnection connection)
void	shutdown()
void	start()
ClientConnection	tryToConnect(Address target)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BUFFER_SIZE

public static final int BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

ClientConnectionManagerImpl

public ClientConnectionManagerImpl(HazelcastClient client,
                                   LoadBalancer loadBalancer)

Method Detail

isLive

public boolean isLive()

getSerializationContext

public SerializationContext getSerializationContext()

getSerializationService

public SerializationService getSerializationService()

start

public void start()

Specified by:

start in interface ClientConnectionManager

shutdown

public void shutdown()

Specified by:

shutdown in interface ClientConnectionManager

markOwnerAddressAsClosed

public void markOwnerAddressAsClosed()

ownerConnection

public ClientConnection ownerConnection(Address address)
                                 throws Exception

Specified by:

ownerConnection in interface ClientConnectionManager

Throws:

Exception

tryToConnect

public ClientConnection tryToConnect(Address target)
                              throws Exception

Specified by:

tryToConnect in interface ClientConnectionManager

Throws:

Exception

getPrincipal

public ClientPrincipal getPrincipal()

destroyConnection

public void destroyConnection(ClientConnection clientConnection)

removeEventHandler

public boolean removeEventHandler(Integer callId)

Specified by:

removeEventHandler in interface ClientConnectionManager

handlePacket

public void handlePacket(ClientPacket packet)

newCallId

public int newCallId()

sendAndReceive

public Object sendAndReceive(ClientRequest request,
                             ClientConnection connection)
                      throws Exception

Throws:

Exception