public class Client extends Object implements AutoCloseable
Constructor and Description |
---|
Client(SocketAddress address,
ConnectionStateListener listener,
ProtocolOptions options,
List<ClientModule> modules) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
com.google.common.util.concurrent.ListenableFuture<Void> |
connect() |
protected void |
disposeExecutor() |
protected void |
handleInitChannel(io.netty.channel.socket.SocketChannel ch) |
protected void |
handleOperationComplete(com.google.common.util.concurrent.SettableFuture<Void> result,
io.netty.channel.ChannelFuture future) |
void |
writeCommand(Object command) |
public Client(SocketAddress address, ConnectionStateListener listener, ProtocolOptions options, List<ClientModule> modules)
public com.google.common.util.concurrent.ListenableFuture<Void> connect()
protected void handleOperationComplete(com.google.common.util.concurrent.SettableFuture<Void> result, io.netty.channel.ChannelFuture future)
protected void handleInitChannel(io.netty.channel.socket.SocketChannel ch)
public void close() throws Exception
close
in interface AutoCloseable
Exception
protected void disposeExecutor()
public void writeCommand(Object command)