Merge "Integration test added to netconf-it to test identity (de)serialization."

[controller.git] / opendaylight / md-sal / sal-rest-connector / src / main / java / org / opendaylight / controller / sal / streams / websockets / WebSocketServer.java

diff --git a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServer.java b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServer.java
index 142cde14001ebeaab5530ef717ce11e6a498b0f5..d7b4bd9d9e0754c2bfc71958a845820c39eab8f1 100644 (file)
--- a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServer.java
+++ b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServer.java
@@ -6,47 +6,56 @@ import org.slf4j.LoggerFactory;
 
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.Channel;
+import io.netty.channel.ChannelPipeline;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 
+/**
+ * {@link WebSocketServer} is responsible to start and stop web socket server at
+ * {@link #PORT}.
+ */
 public class WebSocketServer implements Runnable {
 
-    private static final Logger logger = LoggerFactory.getLogger(WebSocketServer.class);
-
-    public static final int PORT = 8181;
-    private EventLoopGroup bossGroup;
-    private EventLoopGroup workerGroup;
-
-    @Override
-    public void run() {
-        bossGroup = new NioEventLoopGroup();
-        workerGroup = new NioEventLoopGroup();
-        try {
-            ServerBootstrap b = new ServerBootstrap();
-            b.group(bossGroup, workerGroup)
-                .channel(NioServerSocketChannel.class)
-                .childHandler(new WebSocketServerInitializer());
-
-            Channel ch = b.bind(PORT).sync().channel();
-            logger.info("Web socket server started at port {}.", PORT);
-
-            ch.closeFuture().sync();
-        } catch (InterruptedException e) {
-            // NOOP
-        } finally {
-            stop();
-        }
-    }
-
-    private void stop() {
-        Notificator.removeAllListeners();
-        if (bossGroup != null) {
-            bossGroup.shutdownGracefully();
-        }
-        if (workerGroup != null) {
-            workerGroup.shutdownGracefully();
-        }
-    }
+       private static final Logger logger = LoggerFactory
+                       .getLogger(WebSocketServer.class);
+
+       public static final int PORT = 8181;
+       private EventLoopGroup bossGroup;
+       private EventLoopGroup workerGroup;
+
+       @Override
+       public void run() {
+               bossGroup = new NioEventLoopGroup();
+               workerGroup = new NioEventLoopGroup();
+               try {
+                       ServerBootstrap b = new ServerBootstrap();
+                       b.group(bossGroup, workerGroup)
+                                       .channel(NioServerSocketChannel.class)
+                                       .childHandler(new WebSocketServerInitializer());
+
+                       Channel ch = b.bind(PORT).sync().channel();
+                       logger.info("Web socket server started at port {}.", PORT);
+
+                       ch.closeFuture().sync();
+               } catch (InterruptedException e) {
+                       // NOOP
+               } finally {
+                       stop();
+               }
+       }
+
+       /**
+        * Stops the web socket server and removes all listeners.
+        */
+       private void stop() {
+               Notificator.removeAllListeners();
+               if (bossGroup != null) {
+                       bossGroup.shutdownGracefully();
+               }
+               if (workerGroup != null) {
+                       workerGroup.shutdownGracefully();
+               }
+       }
 
 }