diff --git a/eventbus/src/main/java/com/epita/eventbus/NettyClientInitializer.java b/eventbus/src/main/java/com/epita/eventbus/NettyClientInitializer.java index 161b2b1..4fc7f1e 100644 --- a/eventbus/src/main/java/com/epita/eventbus/NettyClientInitializer.java +++ b/eventbus/src/main/java/com/epita/eventbus/NettyClientInitializer.java @@ -21,7 +21,7 @@ public NettyClientInitializer(Consumer c) { public void initChannel(SocketChannel ch) { final ChannelPipeline pipeline = ch.pipeline(); - pipeline.addLast(new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter())); + pipeline.addLast(new DelimiterBasedFrameDecoder(1048576*2, Delimiters.lineDelimiter())); pipeline.addLast(new StringDecoder()); pipeline.addLast(new StringEncoder()); diff --git a/eventbus/src/main/java/com/epita/eventbus/ServerInitializer.java b/eventbus/src/main/java/com/epita/eventbus/ServerInitializer.java index d8d66d0..3d44cb5 100644 --- a/eventbus/src/main/java/com/epita/eventbus/ServerInitializer.java +++ b/eventbus/src/main/java/com/epita/eventbus/ServerInitializer.java @@ -14,7 +14,7 @@ public class ServerInitializer extends ChannelInitializer { protected void initChannel(SocketChannel socketChannel) { final ChannelPipeline pipeline = socketChannel.pipeline(); - pipeline.addLast(new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter())); + pipeline.addLast(new DelimiterBasedFrameDecoder(1048576*2, Delimiters.lineDelimiter())); pipeline.addLast(new StringDecoder()); pipeline.addLast(new StringEncoder());