public class NettyFabricWorkerExecutionChannelHandler extends io.netty.channel.SimpleChannelInboundHandler<NettyFabricWorkerConfig<Serializable>>
Modifier and Type | Class and Description |
---|---|
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 |
Constructor and Description |
---|
NettyFabricWorkerExecutionChannelHandler(Repository<io.netty.channel.Channel> repository,
FabricAgent fabricAgent,
long executionTimeout) |
Modifier and Type | Method and Description |
---|---|
protected void |
channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext,
NettyFabricWorkerConfig<Serializable> nettyFabricWorkerConfig) |
void |
exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
Throwable throwable) |
protected com.liferay.portal.kernel.concurrent.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) |
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public NettyFabricWorkerExecutionChannelHandler(Repository<io.netty.channel.Channel> repository, FabricAgent fabricAgent, long executionTimeout)
public void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext, Throwable throwable)
exceptionCaught
in interface io.netty.channel.ChannelHandler
exceptionCaught
in interface io.netty.channel.ChannelInboundHandler
exceptionCaught
in class io.netty.channel.ChannelInboundHandlerAdapter
protected void channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext, NettyFabricWorkerConfig<Serializable> nettyFabricWorkerConfig)
channelRead0
in class io.netty.channel.SimpleChannelInboundHandler<NettyFabricWorkerConfig<Serializable>>
protected com.liferay.portal.kernel.concurrent.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)