public class ConnectionManagerImpl extends Object implements ConnectionManager
| Constructor and Description |
|---|
ConnectionManagerImpl(boolean enableSsl,
long heartBeatInterval,
long heartbeatTimeoutThreshold) |
| Modifier and Type | Method and Description |
|---|---|
void |
addConnectionListener(ConnectionListener connectionListener)
add connection listener
|
CompletableFuture<Connection> |
connect(SocketAddress address)
connect
|
List<Connection> |
getConnectionList()
get a connection
|
void |
removeConnectionListener(ConnectionListener connectionListener)
remove connection listener
|
void |
shutdown()
shutdown
close all connection
|
public ConnectionManagerImpl(boolean enableSsl,
long heartBeatInterval,
long heartbeatTimeoutThreshold)
public List<Connection> getConnectionList()
ConnectionManagergetConnectionList in interface ConnectionManagerpublic CompletableFuture<Connection> connect(SocketAddress address)
ConnectionManagerconnect in interface ConnectionManageraddress - addresspublic void shutdown()
ConnectionManagershutdown in interface ConnectionManagerpublic void addConnectionListener(ConnectionListener connectionListener)
ConnectionManageraddConnectionListener in interface ConnectionManagerconnectionListener - listener for connection status changingpublic void removeConnectionListener(ConnectionListener connectionListener)
ConnectionManagerremoveConnectionListener in interface ConnectionManagerconnectionListener - listener for connection status changingCopyright © 2019. All rights reserved.