001
014
015 package com.liferay.portal.fabric.netty.rpc.handlers;
016
017 import com.liferay.portal.fabric.netty.rpc.RPCSerializable;
018
019 import io.netty.channel.ChannelHandler.Sharable;
020 import io.netty.channel.ChannelHandlerContext;
021 import io.netty.channel.SimpleChannelInboundHandler;
022
023
026 @Sharable
027 public class NettyRPCChannelHandler
028 extends SimpleChannelInboundHandler<RPCSerializable> {
029
030 public static final NettyRPCChannelHandler INSTANCE =
031 new NettyRPCChannelHandler();
032
033 public static final String NAME = NettyRPCChannelHandler.class.getName();
034
035 @Override
036 protected void channelRead0(
037 ChannelHandlerContext channelHandlerContext,
038 RPCSerializable rpcSerializable) {
039
040 rpcSerializable.execute(channelHandlerContext.channel());
041 }
042
043 private NettyRPCChannelHandler() {
044 }
045
046 }