protected void addSocketioHandlers(ChannelPipeline pipeline) {
        pipeline.addLast(HTTP_REQUEST_DECODER, new HttpRequestDecoder());
        pipeline.addLast(HTTP_AGGREGATOR, new HttpObjectAggregator(configuration.getMaxHttpContentLength()) {
            @Override
            protected Object newContinueResponse(HttpMessage start, int maxContentLength,
                    ChannelPipeline pipeline) {
                return null;
            }

        });
        pipeline.addLast(HTTP_ENCODER, new HttpResponseEncoder());

        if (configuration.isHttpCompression()) {
            pipeline.addLast(HTTP_COMPRESSION, new HttpContentCompressor());
        }

        pipeline.addLast(PACKET_HANDLER, packetHandler);

        pipeline.addLast(AUTHORIZE_HANDLER, authorizeHandler);
        pipeline.addLast(XHR_POLLING_TRANSPORT, xhrPollingTransport);
        // TODO use single instance when https://github.com/netty/netty/issues/4755 will be resolved
        if (configuration.isWebsocketCompression()) {
            pipeline.addLast(WEB_SOCKET_TRANSPORT_COMPRESSION, new WebSocketServerCompressionHandler());
        }
        pipeline.addLast(WEB_SOCKET_TRANSPORT, webSocketTransport);

        pipeline.addLast(SOCKETIO_ENCODER, encoderHandler);

        pipeline.addLast(WRONG_URL_HANDLER, wrongUrlHandler);
    }
protected void addSocketioHandlers ( ChannelPipeline pipeline ) { pipeline . addLast ( HTTP_REQUEST_DECODER , new HttpRequestDecoder ( ) ) ; pipeline . addLast ( HTTP_AGGREGATOR , new HttpObjectAggregator ( configuration . getMaxHttpContentLength ( ) ) { @ Override protected Object newContinueResponse ( HttpMessage start , int maxContentLength , ChannelPipeline pipeline ) { return null ; } } ) ; pipeline . addLast ( HTTP_ENCODER , new HttpResponseEncoder ( ) ) ; if ( configuration . isHttpCompression ( ) ) { pipeline . addLast ( HTTP_COMPRESSION , new HttpContentCompressor ( ) ) ; } pipeline . addLast ( PACKET_HANDLER , packetHandler ) ; pipeline . addLast ( AUTHORIZE_HANDLER , authorizeHandler ) ; pipeline . addLast ( XHR_POLLING_TRANSPORT , xhrPollingTransport ) ; if ( configuration . isWebsocketCompression ( ) ) { pipeline . addLast ( WEB_SOCKET_TRANSPORT_COMPRESSION , new WebSocketServerCompressionHandler ( ) ) ; } pipeline . addLast ( WEB_SOCKET_TRANSPORT , webSocketTransport ) ; pipeline . addLast ( SOCKETIO_ENCODER , encoderHandler ) ; pipeline . addLast ( WRONG_URL_HANDLER , wrongUrlHandler ) ; }
Adds the socketio channel handlers

@param pipeline - channel pipeline