Apply style rules on whole sal-rest-connector

[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 20951b01e2dd52a16b80cb5794d049c858eb2d82..67ed44f84ea86020b54553f3f0b4f108e4ada66f 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
@@ -1,24 +1,21 @@
 package org.opendaylight.controller.sal.streams.websockets;
 
+import com.google.common.base.Preconditions;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.Channel;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
-
 import org.opendaylight.controller.sal.streams.listeners.Notificator;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.google.common.base.Preconditions;
-
 /**
  * {@link WebSocketServer} is responsible to start and stop web socket server
  */
 public class WebSocketServer implements Runnable {
 
-    private static final Logger logger = LoggerFactory
-            .getLogger(WebSocketServer.class);
+    private static final Logger logger = LoggerFactory.getLogger(WebSocketServer.class);
     public static final String WEBSOCKET_SERVER_CONFIG_PROPERTY = "restconf.websocket.port";
     public static final int DEFAULT_PORT = 8181;
     private EventLoopGroup bossGroup;
@@ -32,14 +29,16 @@ public class WebSocketServer implements Runnable {
 
     /**
      * Create instance of {@link WebSocketServer}
-     * @param port TCP port used for this server
+     *
+     * @param port
+     *            TCP port used for this server
      * @return instance of {@link WebSocketServer}
      */
     public static WebSocketServer createInstance(int port) {
-        if(singleton != null) {
+        if (singleton != null) {
             throw new IllegalStateException("createInstance() has already been called");
         }
-        if(port < 1024) {
+        if (port < 1024) {
             throw new IllegalArgumentException("Privileged port (below 1024) is not allowed");
         }
         singleton = new WebSocketServer(port);
@@ -55,11 +54,11 @@ public class WebSocketServer implements Runnable {
 
     /**
      * Get instance of {@link WebSocketServer} created by {@link #createInstance(int)}
+     *
      * @return instance of {@link WebSocketServer}
      */
     public static WebSocketServer getInstance() {
-        Preconditions.checkNotNull(singleton,
-                "createInstance() must be called prior to getInstance()");
+        Preconditions.checkNotNull(singleton, "createInstance() must be called prior to getInstance()");
         return singleton;
     }
 
@@ -67,9 +66,8 @@ public class WebSocketServer implements Runnable {
      * Destroy this already created instance
      */
     public static void destroyInstance() {
-        if(singleton == null) {
-            throw new IllegalStateException(
-                    "createInstance() must be called prior to destroyInstance()");
+        if (singleton == null) {
+            throw new IllegalStateException("createInstance() must be called prior to destroyInstance()");
         }
         getInstance().stop();
     }
@@ -80,8 +78,7 @@ public class WebSocketServer implements Runnable {
         workerGroup = new NioEventLoopGroup();
         try {
             ServerBootstrap b = new ServerBootstrap();
-            b.group(bossGroup, workerGroup)
-                    .channel(NioServerSocketChannel.class)
+            b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
                     .childHandler(new WebSocketServerInitializer());
 
             Channel ch = b.bind(port).sync().channel();