public class TcpIpConnectionManager extends Object implements ConnectionManager
Constructor and Description |
---|
TcpIpConnectionManager(IOService ioService,
ServerSocketChannel serverSocketChannel) |
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() |
public TcpIpConnectionManager(IOService ioService, ServerSocketChannel serverSocketChannel)
public int getActiveConnectionCount()
getActiveConnectionCount
in interface ConnectionManager
public int getAllTextConnections()
getAllTextConnections
in interface ConnectionManager
public int getConnectionCount()
getConnectionCount
in interface ConnectionManager
public boolean isSSLEnabled()
isSSLEnabled
in interface ConnectionManager
public void incrementTextConnections()
public SerializationContext getSerializationContext()
public IOService getIOHandler()
public MemberSocketInterceptor getMemberSocketInterceptor()
public void addConnectionListener(ConnectionListener listener)
addConnectionListener
in interface ConnectionManager
public boolean bind(TcpIpConnection connection, Address remoteEndPoint, Address localEndpoint, boolean replyBack)
public Connection getConnection(Address address)
getConnection
in interface ConnectionManager
public Connection getOrConnect(Address address)
getOrConnect
in interface ConnectionManager
public Connection getOrConnect(Address address, boolean silent)
getOrConnect
in interface ConnectionManager
public void destroyConnection(Connection connection)
destroyConnection
in interface ConnectionManager
public void start()
start
in interface ConnectionManager
public void restart()
restart
in interface ConnectionManager
public void shutdown()
shutdown
in interface ConnectionManager
public int getCurrentClientConnections()
getCurrentClientConnections
in interface ConnectionManager
public boolean isLive()
public Map<Address,Connection> getReadonlyConnectionMap()
getReadonlyConnectionMap
in interface ConnectionManager
Copyright © 2014 Hazelcast, Inc.. All rights reserved.