com.hazelcast.nio

Class TcpIpConnectionManager

java.lang.Object

com.hazelcast.nio.TcpIpConnectionManager

All Implemented Interfaces:

ConnectionManager

public class TcpIpConnectionManager
extends Object
implements ConnectionManager

Constructor Summary

Constructors

Constructor and Description
TcpIpConnectionManager(IOService ioService, ServerSocketChannel serverSocketChannel)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener listener)
boolean	bind(TcpIpConnection connection, Address remoteEndPoint, Address localEndpoint, boolean replyBack)
void	destroyConnection(Connection connection)
int	getActiveConnectionCount()
int	getAllTextConnections()
Connection	getConnection(Address address)
int	getConnectionCount()
int	getCurrentClientConnections()
IOService	getIOHandler()
MemberSocketInterceptor	getMemberSocketInterceptor()
Connection	getOrConnect(Address address)
Connection	getOrConnect(Address address, boolean silent)
Map<Address,Connection>	getReadonlyConnectionMap()
SerializationContext	getSerializationContext()
void	incrementTextConnections()
protected void	initSocket(Socket socket)
boolean	isLive()
boolean	isSSLEnabled()
void	restart()
void	shutdown()
void	start()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpIpConnectionManager

public TcpIpConnectionManager(IOService ioService,
                              ServerSocketChannel serverSocketChannel)

Method Detail

getActiveConnectionCount

public int getActiveConnectionCount()

Specified by:

getActiveConnectionCount in interface ConnectionManager

getAllTextConnections

public int getAllTextConnections()

Specified by:

getAllTextConnections in interface ConnectionManager

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface ConnectionManager

isSSLEnabled

public boolean isSSLEnabled()

Specified by:

isSSLEnabled in interface ConnectionManager

incrementTextConnections

public void incrementTextConnections()

getSerializationContext

public SerializationContext getSerializationContext()

getIOHandler

public IOService getIOHandler()

getMemberSocketInterceptor

public MemberSocketInterceptor getMemberSocketInterceptor()

addConnectionListener

public void addConnectionListener(ConnectionListener listener)

Specified by:

addConnectionListener in interface ConnectionManager

bind

public boolean bind(TcpIpConnection connection,
                    Address remoteEndPoint,
                    Address localEndpoint,
                    boolean replyBack)

getConnection

public Connection getConnection(Address address)

Specified by:

getConnection in interface ConnectionManager

getOrConnect

public Connection getOrConnect(Address address)

Specified by:

getOrConnect in interface ConnectionManager

getOrConnect

public Connection getOrConnect(Address address,
                               boolean silent)

Specified by:

getOrConnect in interface ConnectionManager

destroyConnection

public void destroyConnection(Connection connection)

Specified by:

destroyConnection in interface ConnectionManager

initSocket

protected void initSocket(Socket socket)
                   throws Exception

Throws:

Exception

start

public void start()

Specified by:

start in interface ConnectionManager

restart

public void restart()

Specified by:

restart in interface ConnectionManager

shutdown

public void shutdown()

Specified by:

shutdown in interface ConnectionManager

getCurrentClientConnections

public int getCurrentClientConnections()

Specified by:

getCurrentClientConnections in interface ConnectionManager

isLive

public boolean isLive()

getReadonlyConnectionMap

public Map<Address,Connection> getReadonlyConnectionMap()

Specified by:

getReadonlyConnectionMap in interface ConnectionManager

toString

public String toString()

Overrides:

toString in class Object