Liferay 7.0-ce-b4

com.liferay.portal.fabric.netty.handlers
Class NettyFabricWorkerExecutionChannelHandler

java.lang.Object
  extended by io.netty.channel.ChannelHandlerAdapter
      extended by io.netty.channel.ChannelInboundHandlerAdapter
          extended by io.netty.channel.SimpleChannelInboundHandler<NettyFabricWorkerConfig<Serializable>>
              extended by com.liferay.portal.fabric.netty.handlers.NettyFabricWorkerExecutionChannelHandler
All Implemented Interfaces:
io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public class NettyFabricWorkerExecutionChannelHandler
extends io.netty.channel.SimpleChannelInboundHandler<NettyFabricWorkerConfig<Serializable>>


Nested Class Summary
protected static class NettyFabricWorkerExecutionChannelHandler.FabricAgentFinishStartupProcessCallable
           
protected static class NettyFabricWorkerExecutionChannelHandler.FabricWorkerResultProcessCallable
           
protected static class NettyFabricWorkerExecutionChannelHandler.LoadedPaths
           
protected  class NettyFabricWorkerExecutionChannelHandler.PostFabricWorkerExecutionFutureListener
           
protected  class NettyFabricWorkerExecutionChannelHandler.PostFabricWorkerFinishFutureListener
           
protected  class NettyFabricWorkerExecutionChannelHandler.PostLoadPathsFutureListener
           
 
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
io.netty.channel.ChannelHandler.Sharable
 
Constructor Summary
NettyFabricWorkerExecutionChannelHandler(Repository<io.netty.channel.Channel> repository, FabricAgent fabricAgent, long executionTimeout)
           
 
Method Summary
protected  void channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext, NettyFabricWorkerConfig<Serializable> nettyFabricWorkerConfig)
           
 void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext, Throwable throwable)
           
protected  NoticeableFuture<NettyFabricWorkerExecutionChannelHandler.LoadedPaths> loadPaths(io.netty.channel.Channel channel, NettyFabricWorkerConfig<Serializable> nettyFabricWorkerConfig)
           
protected  void sendResult(io.netty.channel.Channel channel, long fabricWorkerId, Serializable result, Throwable t)
           
 
Methods inherited from class io.netty.channel.SimpleChannelInboundHandler
acceptInboundMessage, channelRead
 
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
 
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
handlerAdded, handlerRemoved, isSharable
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded, handlerRemoved
 

Constructor Detail

NettyFabricWorkerExecutionChannelHandler

public NettyFabricWorkerExecutionChannelHandler(Repository<io.netty.channel.Channel> repository,
                                                FabricAgent fabricAgent,
                                                long executionTimeout)
Method Detail

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
                            Throwable throwable)
Specified by:
exceptionCaught in interface io.netty.channel.ChannelHandler
Specified by:
exceptionCaught in interface io.netty.channel.ChannelInboundHandler
Overrides:
exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext,
                            NettyFabricWorkerConfig<Serializable> nettyFabricWorkerConfig)
Specified by:
channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<NettyFabricWorkerConfig<Serializable>>

loadPaths

protected NoticeableFuture<NettyFabricWorkerExecutionChannelHandler.LoadedPaths> loadPaths(io.netty.channel.Channel channel,
                                                                                           NettyFabricWorkerConfig<Serializable> nettyFabricWorkerConfig)

sendResult

protected void sendResult(io.netty.channel.Channel channel,
                          long fabricWorkerId,
                          Serializable result,
                          Throwable t)

Liferay 7.0-ce-b4