mysocketinitialiser.java

/**
 * Performs the initial set up of sockets as they connect to Netty.
 * Registers the pipeline of handlers that received messages are passed through
 */
public class MySocketInitialiser extends ChannelInitializer<SocketChannel> {

    @Override
    public void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        pipeline.addLast(LineBasedFrameDecoder.class.getName(),
                new LineBasedFrameDecoder(256));

        pipeline.addLast(StringDecoder.class.getName(),
                new StringDecoder(CharsetUtil.UTF_8));

        pipeline.addLast(JsonDecoder.class.getName(),
                new JsonDecoder<>(Person.class));

        pipeline.addLast("stdoutHandler",
                new ChannelInboundMessageHandlerAdapter<Person>() {
                    @Override
                    public void messageReceived(ChannelHandlerContext ctx, Person person) throws Exception {
                        System.out.println(
                                "Your name is " + person.getFirstName() + " " + person.getLastName() + "!"
                        );
                    }
                }
        );
}