com.liferay.portal.fabric.netty.handlers
Class NettyFabricWorkerExecutionChannelHandler
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.SimpleChannelInboundHandler<NettyFabricWorkerConfig<Serializable>>
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 classes/interfaces inherited from interface io.netty.channel.ChannelHandler |
io.netty.channel.ChannelHandler.Sharable |
| 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 |
NettyFabricWorkerExecutionChannelHandler
public NettyFabricWorkerExecutionChannelHandler(Repository<io.netty.channel.Channel> repository,
FabricAgent fabricAgent,
long executionTimeout)
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)