src/main/java/io/mantisrx/api/initializers/MantisApiServerChannelInitializer.java
protected void addPushHandlers(final ChannelPipeline pipeline, String url) {
        pipeline.addLast(new ChunkedWriteHandler());
        pipeline.addLast(new HttpObjectAggregator(64 * 1024));
        pipeline.addLast(new MantisSSEHandler(connectionBroker, masterClientWrapper, pushPrefixes));
        pipeline.addLast(new WebSocketServerProtocolHandler(url, true));
        pipeline.addLast(new MantisWebSocketFrameHandler(connectionBroker));
    }
/**
     * Adds a series of handlers for providing SSE/Websocket connections
     * to Mantis Jobs.
     *
     * @param pipeline The netty pipeline to which push handlers should be added.
     * @param url The url with which to initiate the websocket handler.
     */
Adds a series of handlers for providing SSE/Websocket connections
to Mantis Jobs.

@param pipeline The netty pipeline to which push handlers should be added.
@param url The url with which to initiate the websocket handler.
Adds a series of handlers for providing SSE / Websocket connections to Mantis Jobs . @param pipeline The netty pipeline to which push handlers should be added . @param url The url with which to initiate the websocket handler .
protected void addPushHandlers(final ChannelPipeline pipeline, String url) {
        pipeline.addLast(new ChunkedWriteHandler());
        pipeline.addLast(new HttpObjectAggregator(64 * 1024));
        pipeline.addLast(new MantisSSEHandler(connectionBroker, masterClientWrapper, pushPrefixes));
        pipeline.addLast(new WebSocketServerProtocolHandler(url, true));
        pipeline.addLast(new MantisWebSocketFrameHandler(connectionBroker));
    }
protected void addPushHandlers ( final ChannelPipeline pipeline , String url ) { pipeline . addLast ( new ChunkedWriteHandler ( ) ) ; pipeline . addLast ( new HttpObjectAggregator ( 64 * 1024 ) ) ; pipeline . addLast ( new MantisSSEHandler ( connectionBroker , masterClientWrapper , pushPrefixes ) ) ; pipeline . addLast ( new WebSocketServerProtocolHandler ( url , true ) ) ; pipeline . addLast ( new MantisWebSocketFrameHandler ( connectionBroker ) ) ; }
Adds a series of handlers for providing SSE/Websocket connections
 to Mantis Jobs.
Adds a series of handlers for providing SSE / Websocket connections to Mantis Jobs .