public class NettyFabricServer extends Object implements FabricServer
Modifier and Type | Class and Description |
---|---|
protected class |
NettyFabricServer.ChildChannelInitializer |
protected class |
NettyFabricServer.PostBindChannelFutureListener |
protected class |
NettyFabricServer.PostShutdownChannelListener |
Constructor and Description |
---|
NettyFabricServer(FabricAgentRegistry fabricAgentRegistry,
NettyFabricServerConfig nettyFabricServerConfig) |
Modifier and Type | Method and Description |
---|---|
protected io.netty.util.concurrent.EventExecutorGroup |
createEventExecutorGroup(int threadCount,
String threadPoolName) |
void |
start() |
Future<?> |
stop() |
public NettyFabricServer(FabricAgentRegistry fabricAgentRegistry, NettyFabricServerConfig nettyFabricServerConfig)
public void start() throws Exception
start
in interface FabricServer
Exception
public Future<?> stop() throws InterruptedException
stop
in interface FabricServer
InterruptedException
protected io.netty.util.concurrent.EventExecutorGroup createEventExecutorGroup(int threadCount, String threadPoolName)