com.liferay.portal.fabric.netty.client
Class NettyFabricClient
java.lang.Object
com.liferay.portal.fabric.netty.client.NettyFabricClient
- All Implemented Interfaces:
- FabricClient
public class NettyFabricClient
- extends Object
- implements FabricClient
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
NettyFabricClient
public NettyFabricClient(ProcessExecutor processExecutor,
NettyFabricClientConfig nettyFabricClientConfig,
NettyFabricClientShutdownCallback nettyFabricClientShutdownCallback)
connect
public void connect()
- Specified by:
connect in interface FabricClient
disconnect
public void disconnect()
throws InterruptedException
- Specified by:
disconnect in interface FabricClient
- Throws:
InterruptedException
disposeRepository
protected void disposeRepository(io.netty.channel.Channel channel)
doConnect
protected void doConnect()
doDisconnect
protected void doDisconnect()
throws InterruptedException
- Throws:
InterruptedException
getEventExecutorGroup
protected io.netty.util.concurrent.EventExecutorGroup getEventExecutorGroup(io.netty.channel.Channel channel,
io.netty.util.AttributeKey<io.netty.util.concurrent.EventExecutorGroup> attributeKey)
getRepository
protected Repository<io.netty.channel.Channel> getRepository(io.netty.channel.Channel channel)
throws IOException
- Throws:
IOException
registerNettyFabricAgent
protected void registerNettyFabricAgent()
throws IOException
- Throws:
IOException
shutdownEventExecutorGroup
protected void shutdownEventExecutorGroup(io.netty.channel.Channel channel,
io.netty.util.AttributeKey<io.netty.util.concurrent.EventExecutorGroup> attributeKey)
terminateFabricWorkers
protected void terminateFabricWorkers(io.netty.channel.Channel channel)