@@ -0,0 +1,716 @@
+package io.elssa.net;%0A%0Aimport io.netty.channel.ChannelInitializer;%0Aimport io.netty.channel.socket.SocketChannel;%0A%0Apublic class MessagePipeline extends ChannelInitializer%3CSocketChannel%3E %7B%0A%0A    private InboundHandler inboundHandler;%0A    private MessageEncoder encoder;%0A%0A    public MessagePipeline(MessageRouterBase router) %7B%0A        inboundHandler = new InboundHandler(router);%0A        encoder = new MessageEncoder();%0A    %7D%0A%0A    @Override%0A    public void initChannel(SocketChannel ch) throws Exception %7B%0A        /* Inbound: */%0A        ch.pipeline().addLast(new MessageDecoder()); /* (stateful) */%0A        ch.pipeline().addLast(inboundHandler);%0A%0A        /* Outbound: */%0A        ch.pipeline().addLast(encoder);%0A    %7D%0A%0A%7D%0A

Add a shared ChannelInitializer