Higher limit of frame size

dethi · Dec 9, 2017 · 98a6dbf · 98a6dbf
1 parent 654fb06
commit 98a6dbf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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<EventMessage> 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
@@ -14,7 +14,7 @@ public class ServerInitializer extends ChannelInitializer<SocketChannel> {
     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());