@Override
    protected void initChannel(Channel channel) throws Exception {
        channel.pipeline().addLast(new ByteArrayDecoder());
        channel.pipeline().addLast(this.handler);
    }
@Test
    public void testChannelInitializer() throws Exception {
        NioSocketChannel channel = new NioSocketChannel();

        NettyTCPChannelInitializer nettyChannelInitializer = new NettyTCPChannelInitializer(
                new NettyTCPServerHandler(new NettySource()));
        nettyChannelInitializer.initChannel(channel);

        assertNotNull(channel.pipeline().toMap());
        assertEquals(2, channel.pipeline().toMap().size());
    }