Introduce a config parameter for websocket max frame size, close AsyncHttpClient#675

Author: Stephane Landelle

src/main/java/com/ning/http/client/providers/netty/NettyAsyncHttpProviderConfig.java

@@ -135,6 +135,8 @@ public Set<Map.Entry<String, Object>> propertiesSet() {
 
     private int webSocketMaxBufferSize = 128000000;
 
+    private int webSocketMaxFrameSize = 10 * 1024;
+
     public boolean isUseDeadLockChecker() {
         return useDeadLockChecker;
     }
@@ -246,6 +248,14 @@ public int getWebSocketMaxBufferSize() {
     public void setWebSocketMaxBufferSize(int webSocketMaxBufferSize) {
         this.webSocketMaxBufferSize = webSocketMaxBufferSize;
     }
+    
+    public int getWebSocketMaxFrameSize() {
+        return webSocketMaxFrameSize;
+    }
+
+    public void setWebSocketMaxFrameSize(int webSocketMaxFrameSize) {
+        this.webSocketMaxFrameSize = webSocketMaxFrameSize;
+    }
 
     public static interface NettyWebSocketFactory {
         NettyWebSocket newNettyWebSocket(Channel channel, NettyAsyncHttpProviderConfig nettyConfig);

src/main/java/com/ning/http/client/providers/netty/channel/ChannelManager.java

@@ -419,8 +419,8 @@ public ClientBootstrap getBootstrap(String scheme, boolean useProxy, boolean use
     public void upgradePipelineForWebSockets(ChannelPipeline pipeline) {
         pipeline.addAfter(HTTP_HANDLER, WS_ENCODER_HANDLER, new WebSocket08FrameEncoder(true));
         pipeline.remove(HTTP_HANDLER);
-        pipeline.addBefore(WS_PROCESSOR, WS_DECODER_HANDLER, new WebSocket08FrameDecoder(false, false, 10 * 1024));
-        pipeline.addAfter(WS_DECODER_HANDLER, WS_FRAME_AGGREGATOR, new WebSocketFrameAggregator(10 * 1024));
+        pipeline.addBefore(WS_PROCESSOR, WS_DECODER_HANDLER, new WebSocket08FrameDecoder(false, false, nettyConfig.getWebSocketMaxFrameSize()));
+        pipeline.addAfter(WS_DECODER_HANDLER, WS_FRAME_AGGREGATOR, new WebSocketFrameAggregator(nettyConfig.getWebSocketMaxBufferSize()));
     }
 
     public final Callback newDrainCallback(final NettyResponseFuture<?> future, final Channel channel, final boolean keepAlive,