Liferay 7.0-ce-m3

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
           
 
Constructor Summary
NettyFabricClient(ProcessExecutor processExecutor, NettyFabricClientConfig nettyFabricClientConfig, NettyFabricClientShutdownCallback nettyFabricClientShutdownCallback)
           
 
Method Summary
 void connect()
           
 void disconnect()
           
protected  void disposeRepository(io.netty.channel.Channel channel)
           
protected  void doConnect()
           
protected  void doDisconnect()
           
protected  io.netty.util.concurrent.EventExecutorGroup getEventExecutorGroup(io.netty.channel.Channel channel, io.netty.util.AttributeKey<io.netty.util.concurrent.EventExecutorGroup> attributeKey)
           
protected  Repository<io.netty.channel.Channel> getRepository(io.netty.channel.Channel channel)
           
protected  void registerNettyFabricAgent()
           
protected  void shutdownEventExecutorGroup(io.netty.channel.Channel channel, io.netty.util.AttributeKey<io.netty.util.concurrent.EventExecutorGroup> attributeKey)
           
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 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)

Liferay 7.0-ce-m3