Skip to content

Commit

Permalink
Merge 68f4898 into 08e2545
Browse files Browse the repository at this point in the history
  • Loading branch information
diegosalvi committed Nov 20, 2019
2 parents 08e2545 + 68f4898 commit b42671c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -222,13 +222,13 @@ public void initChannel(SocketChannel ch) throws Exception {

ch.pipeline().addLast("lengthprepender", new LengthFieldPrepender(4));
ch.pipeline().addLast("lengthbaseddecoder", new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4));
//
ch.pipeline().addLast("messageencoder", new DataMessageEncoder());
ch.pipeline().addLast("messagedecoder", new DataMessageDecoder());
ch.pipeline().addLast(new InboundMessageHandler(session));
}
})
.option(ChannelOption.SO_BACKLOG, 128)
.option(ChannelOption.SO_REUSEADDR, true)
.childOption(ChannelOption.SO_KEEPALIVE, true);

ChannelFuture f = b.bind(host, port).sync(); // (7)
Expand Down

0 comments on commit b42671c

Please sign in to comment.