public class ReactorNettyTcpClient<P> extends java.lang.Object implements TcpOperations<P>
TcpOperations
.Constructor and Description |
---|
ReactorNettyTcpClient(java.util.function.Consumer<reactor.ipc.netty.options.ClientOptions.Builder<?>> optionsConsumer,
ReactorNettyCodec<P> codec)
Alternate constructor with a
ClientOptions.Builder> consumer
providing additional control beyond a host and a port. |
ReactorNettyTcpClient(java.lang.String host,
int port,
ReactorNettyCodec<P> codec)
Basic constructor with a host and a port.
|
Modifier and Type | Method and Description |
---|---|
ListenableFuture<java.lang.Void> |
connect(TcpConnectionHandler<P> handler)
Open a new connection.
|
ListenableFuture<java.lang.Void> |
connect(TcpConnectionHandler<P> handler,
ReconnectStrategy strategy)
Open a new connection and a strategy for reconnecting if the connection fails.
|
ListenableFuture<java.lang.Void> |
shutdown()
Shut down and close any open connections.
|
public ReactorNettyTcpClient(java.lang.String host, int port, ReactorNettyCodec<P> codec)
public ReactorNettyTcpClient(java.util.function.Consumer<reactor.ipc.netty.options.ClientOptions.Builder<?>> optionsConsumer, ReactorNettyCodec<P> codec)
ClientOptions.Builder>
consumer
providing additional control beyond a host and a port.public ListenableFuture<java.lang.Void> connect(TcpConnectionHandler<P> handler)
TcpOperations
connect
in interface TcpOperations<P>
handler
- a handler to manage the connectionpublic ListenableFuture<java.lang.Void> connect(TcpConnectionHandler<P> handler, ReconnectStrategy strategy)
TcpOperations
connect
in interface TcpOperations<P>
handler
- a handler to manage the connectionstrategy
- a strategy for reconnectingpublic ListenableFuture<java.lang.Void> shutdown()
TcpOperations
shutdown
in interface TcpOperations<P>