public class ReactorNettyTcpClient<P> extends Object implements TcpOperations<P>
TcpOperations
.Constructor and Description |
---|
ReactorNettyTcpClient(String host,
int port,
reactor.tcp.encoding.Codec<reactor.io.Buffer,Message<P>,Message<P>> codec) |
Modifier and Type | Method and Description |
---|---|
ListenableFuture<Void> |
connect(TcpConnectionHandler<P> connectionHandler)
Open a new connection.
|
ListenableFuture<Void> |
connect(TcpConnectionHandler<P> connectionHandler,
ReconnectStrategy reconnectStrategy)
Open a new connection and a strategy for reconnecting if the connection fails.
|
ListenableFuture<Void> |
shutdown()
Shut down and close any open connections.
|
public ListenableFuture<Void> connect(TcpConnectionHandler<P> connectionHandler)
TcpOperations
connect
in interface TcpOperations<P>
connectionHandler
- a handler to manage the connectionpublic ListenableFuture<Void> connect(TcpConnectionHandler<P> connectionHandler, ReconnectStrategy reconnectStrategy)
TcpOperations
connect
in interface TcpOperations<P>
connectionHandler
- a handler to manage the connectionreconnectStrategy
- a strategy for reconnectingpublic ListenableFuture<Void> shutdown()
TcpOperations
shutdown
in interface TcpOperations<P>