001package org.xbib.elasticsearch.http.netty;
002
003import org.jboss.netty.channel.ChannelPipeline;
004
005/**
006 * Netty implementation for a WebSocket server pipeline factory.
007 * It is based on the HTTP server pipeline factory.
008 */
009public class NettyWebSocketServerPipelineFactory extends NettyHttpServerPipelineFactory {
010
011    private final NettyWebSocketRequestHandler handler;
012
013    public NettyWebSocketServerPipelineFactory(NettyWebSocketServerTransport transport) {
014        super(transport);
015        this.handler = new NettyWebSocketRequestHandler(transport);
016    }
017
018    @Override
019    public ChannelPipeline getPipeline() throws Exception {
020        ChannelPipeline pipeline = super.getPipeline();
021        pipeline.replace("handler", "handler", handler);
022        return pipeline;
023    }
024}