public class NettyFabricClient extends Object implements FabricClient
| Modifier and Type | Class and Description |
|---|---|
protected class |
NettyFabricClient.NettyFabricClientChannelInitializer |
protected class |
NettyFabricClient.PostConnectChannelFutureListener |
protected class |
NettyFabricClient.PostDisconnectChannelFutureListener |
protected class |
NettyFabricClient.PostRegisterChannelFutureListener |
protected class |
NettyFabricClient.PostShutdownChannelFutureListener |
| Constructor and Description |
|---|
NettyFabricClient(com.liferay.petra.process.ProcessExecutor processExecutor,
NettyFabricClientConfig nettyFabricClientConfig,
NettyFabricClientShutdownCallback nettyFabricClientShutdownCallback) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect() |
protected io.netty.util.concurrent.EventExecutorGroup |
createEventExecutorGroup(int threadCount,
String threadPoolName) |
Future<?> |
disconnect() |
protected void |
doConnect() |
protected void |
terminateFabricWorkers(io.netty.channel.Channel channel) |
public NettyFabricClient(com.liferay.petra.process.ProcessExecutor processExecutor,
NettyFabricClientConfig nettyFabricClientConfig,
NettyFabricClientShutdownCallback nettyFabricClientShutdownCallback)
public void connect()
connect in interface FabricClientpublic Future<?> disconnect()
disconnect in interface FabricClientprotected io.netty.util.concurrent.EventExecutorGroup createEventExecutorGroup(int threadCount,
String threadPoolName)
protected void doConnect()
protected void terminateFabricWorkers(io.netty.channel.Channel channel)