public class ConnectionManager extends Object
Constructor and Description |
---|
ConnectionManager(IOService ioService,
ServerSocketChannel serverSocketChannel) |
Modifier and Type | Method and Description |
---|---|
void |
addConnectionListener(ConnectionListener listener) |
void |
appendState(StringBuffer sbState) |
void |
attachConnection(Address address,
Connection conn) |
boolean |
bind(Connection connection,
Address remoteEndPoint,
Address localEndpoint,
boolean replyBack) |
void |
destroyConnection(Connection connection) |
Connection |
detachAndGetConnection(Address address) |
int |
getAllTextConnections() |
Connection |
getConnection(Address address) |
int |
getCurrentClientConnections() |
IOService |
getIOHandler() |
MemberSocketInterceptor |
getMemberSocketInterceptor() |
Connection |
getOrConnect(Address address) |
Connection |
getOrConnect(Address address,
boolean silent) |
Map<Address,Connection> |
getReadonlyConnectionMap() |
int |
getTotalWriteQueueSize() |
void |
incrementTextConnections() |
protected void |
initSocket(Socket socket) |
boolean |
isLive() |
void |
onRestart() |
void |
shutdown() |
void |
start() |
String |
toString() |
protected final ILogger logger
public ConnectionManager(IOService ioService, ServerSocketChannel serverSocketChannel)
public IOService getIOHandler()
public MemberSocketInterceptor getMemberSocketInterceptor()
public void addConnectionListener(ConnectionListener listener)
public boolean bind(Connection connection, Address remoteEndPoint, Address localEndpoint, boolean replyBack)
public Connection getConnection(Address address)
public Connection getOrConnect(Address address)
public Connection getOrConnect(Address address, boolean silent)
public Connection detachAndGetConnection(Address address)
public void attachConnection(Address address, Connection conn)
public void destroyConnection(Connection connection)
public int getTotalWriteQueueSize()
public void start()
public void onRestart()
public void shutdown()
public int getCurrentClientConnections()
public int getAllTextConnections()
public void incrementTextConnections()
public boolean isLive()
public Map<Address,Connection> getReadonlyConnectionMap()
public void appendState(StringBuffer sbState)
Copyright © 2013 Hazelcast, Inc.. All rights reserved.