com.liferay.portal.fabric.netty.client

Class NettyFabricClient

Object

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

All Implemented Interfaces:

FabricClient

public class NettyFabricClient
extends Object
implements FabricClient

Author:

Shuyang Zhou

Nested Class Summary

Nested Classes

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 Summary

Constructors

Constructor and Description
NettyFabricClient(com.liferay.portal.kernel.process.ProcessExecutor processExecutor, NettyFabricClientConfig nettyFabricClientConfig, NettyFabricClientShutdownCallback nettyFabricClientShutdownCallback)

Method Summary

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)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NettyFabricClient

public NettyFabricClient(com.liferay.portal.kernel.process.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)