opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServerInitializer.java

   1 package org.opendaylight.controller.sal.streams.websockets;
   2
   3 import io.netty.channel.ChannelInitializer;
   4 import io.netty.channel.ChannelPipeline;
   5 import io.netty.channel.socket.SocketChannel;
   6 import io.netty.handler.codec.http.HttpObjectAggregator;
   7 import io.netty.handler.codec.http.HttpServerCodec;
   8
   9 /**
  10  * {@link WebSocketServerInitializer} is used to setup the {@link ChannelPipeline} of a {@link io.netty.channel.Channel}
  11  * .
  12  */
  13 public class WebSocketServerInitializer extends ChannelInitializer<SocketChannel> {
  14
  15     @Override
  16     protected void initChannel(final SocketChannel ch) throws Exception {
  17         ChannelPipeline pipeline = ch.pipeline();
  18         pipeline.addLast("codec-http", new HttpServerCodec());
  19         pipeline.addLast("aggregator", new HttpObjectAggregator(65536));
  20         pipeline.addLast("handler", new WebSocketServerHandler());
  21     }
  22
  23 }