Maximum http content length limit added as configuration property

src/main/java/com/corundumstudio/socketio/Configuration.java

@@ -16,11 +16,11 @@
 package com.corundumstudio.socketio;
 
 import java.io.InputStream;
-import java.util.Arrays;
-import java.util.List;
 import java.util.concurrent.Executor;
 import java.util.concurrent.Executors;
 
+import org.jboss.netty.handler.codec.frame.TooLongFrameException;
+
 import com.corundumstudio.socketio.parser.JacksonJsonSupport;
 import com.corundumstudio.socketio.parser.JsonSupport;
 
@@ -29,7 +29,7 @@ public class Configuration {
     private String jsonTypeFieldName = "@class";
     private String context = "/socket.io";
 
-    private String transports = join(Arrays.asList(Transport.WEBSOCKET, Transport.FLASHSOCKET, Transport.XHRPOLLING));
+    private String transports = join(new Transport[] {Transport.WEBSOCKET, Transport.FLASHSOCKET, Transport.XHRPOLLING});
 
     private Executor bossExecutor = Executors.newCachedThreadPool();
     private Executor workerExecutor = Executors.newCachedThreadPool();
@@ -43,6 +43,8 @@ public class Configuration {
     private int heartbeatInterval = 25;
     private int closeTimeout = 60;
 
+    private int maxHttpContentLength = 64 * 1024;
+
     private String hostname;
     private int port;
 
@@ -76,9 +78,10 @@ public class Configuration {
         setKeyStorePassword(conf.getKeyStorePassword());
         setKeyStore(conf.getKeyStore());
         setTransports(conf.getTransports());
+        setMaxHttpContentLength(conf.getMaxHttpContentLength());
     }
 
-    private String join(List<Transport> transports) {
+    private String join(Transport[] transports) {
         StringBuilder result = new StringBuilder();
         for (Transport transport : transports) {
             result.append(transport.getValue());
@@ -253,13 +256,28 @@ public class Configuration {
         return keyStore;
     }
 
+    /**
+     * Set maximum http content length limit
+     *
+     * @param maxContentLength
+     *        the maximum length of the aggregated http content.
+     *        If the length of the aggregated content exceeds this value,
+     *        a {@link TooLongFrameException} will be raised.
+     */
+    public void setMaxHttpContentLength(int value) {
+        this.maxHttpContentLength = value;
+    }
+    public int getMaxHttpContentLength() {
+        return maxHttpContentLength;
+    }
+
     /**
      * Transports supported by server
      *
      * @param transports - list of transports
      */
-    public void setTransports(List<Transport> transports) {
-        if (transports.isEmpty()) {
+    public void setTransports(Transport ... transports) {
+        if (transports.length == 0) {
             throw new IllegalArgumentException("Transports list can't be empty");
         }
         this.transports = join(transports);

src/main/java/com/corundumstudio/socketio/SocketIOPipelineFactory.java

@@ -141,7 +141,7 @@ public class SocketIOPipelineFactory implements ChannelPipelineFactory, Disconne
         }
 
         pipeline.addLast(HTTP_REQUEST_DECODER, new HttpRequestDecoder());
-        pipeline.addLast(HTTP_AGGREGATOR, new HttpChunkAggregator(65536));
+        pipeline.addLast(HTTP_AGGREGATOR, new HttpChunkAggregator(configuration.getMaxHttpContentLength()));
         pipeline.addLast(HTTP_ENCODER, new HttpResponseEncoder());
 
         if (isFlashTransport) {