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.petra.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, channelReadchannelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharablepublic 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.ChannelHandlerexceptionCaught in interface io.netty.channel.ChannelInboundHandlerexceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapterprotected void channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext,
NettyFabricWorkerConfig<Serializable> nettyFabricWorkerConfig)
channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<NettyFabricWorkerConfig<Serializable>>protected com.liferay.petra.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)