Liferay 7.0-ce-b4

com.liferay.portal.fabric.netty.client
Class NettyFabricClient

java.lang.Object
  extended by com.liferay.portal.fabric.netty.client.NettyFabricClient
All Implemented Interfaces:
FabricClient

public class NettyFabricClient
extends Object
implements FabricClient


Nested Class Summary
protected  class NettyFabricClient.NettyFabricClientChannelInitializer
           
protected  class NettyFabricClient.PostConnectChannelFutureListener
           
protected  class NettyFabricClient.PostDisconnectChannelFutureListener
           
protected  class NettyFabricClient.PostRegisterChannelFutureListener
           
protected  class NettyFabricClient.PostShutdownChannelFutureListener
           
 
Constructor Summary
NettyFabricClient(ProcessExecutor processExecutor, NettyFabricClientConfig nettyFabricClientConfig, NettyFabricClientShutdownCallback nettyFabricClientShutdownCallback)
           
 
Method Summary
 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

NettyFabricClient

public NettyFabricClient(ProcessExecutor processExecutor,
                         NettyFabricClientConfig nettyFabricClientConfig,
                         NettyFabricClientShutdownCallback nettyFabricClientShutdownCallback)
Method Detail

connect

public void connect()
Specified by:
connect in interface FabricClient

disconnect

public Future<?> disconnect()
Specified by:
disconnect in interface FabricClient

createEventExecutorGroup

protected io.netty.util.concurrent.EventExecutorGroup createEventExecutorGroup(int threadCount,
                                                                               String threadPoolName)

doConnect

protected void doConnect()

terminateFabricWorkers

protected void terminateFabricWorkers(io.netty.channel.Channel channel)

Liferay 7.0-ce-b4