Fixed unit tests

Author: egorov-accedo

src/test/java/com/clusterws/ChannelServerTest.java

@@ -16,7 +16,7 @@ public class ChannelServerTest {
 
     @Before
     public void init() throws Exception {
-        mClusterWS = new ClusterWS("ws://localhost:80");
+        mClusterWS = new ClusterWS("ws://localhost:3000");
         mGotTheData = false;
         mReceivedData = null;
     }
@@ -189,7 +189,7 @@ public void onDataReceived(String channelName, Object data) {
                     }
                 });
         mClusterWS.disconnect(4001, "hui");
-        Thread.sleep(1000);
+        Thread.sleep(3000);
         channel.publish("testData");
         Thread.sleep(1000);
         assertTrue("Did not get the data", mGotTheData);

src/test/java/com/clusterws/ClusterWSTest.java

@@ -20,7 +20,7 @@ public class ClusterWSTest {
 
     @Before
     public void init() {
-        mClusterWS = new ClusterWS("ws://localhost:80");
+        mClusterWS = new ClusterWS("ws://localhost:3000");
         receivedData = null;
         gotTheData = false;
     }
@@ -36,7 +36,7 @@ public void connect() throws Exception {
         mClusterWS.connect();
         Thread.sleep(1000);
 
-        assertEquals("Socket did not connect", WebSocket.READYSTATE.OPEN,mClusterWS.getState());
+        assertEquals("Socket did not connect", WebSocket.READYSTATE.OPEN, mClusterWS.getState());
     }
 
     @Test
@@ -233,24 +233,24 @@ public void onDisconnected(int code, String reason) {
     }
 
     @Test
-    public void testReconnection() throws Exception{
-        mClusterWS.setReconnection(true,1000,2000,null);
+    public void testReconnection() throws Exception {
+        mClusterWS.setReconnection(true, 1000, 2000, null);
         mClusterWS.connect();
         Thread.sleep(1000);
-        mClusterWS.disconnect(3002,"test");
-        Thread.sleep(2000);
+        mClusterWS.disconnect(3002, "test");
+        Thread.sleep(4000);
         assertEquals("Did not reconnect", WebSocket.READYSTATE.OPEN, mClusterWS.getState());
     }
 
     @Test
-    public void testPingPong() throws Exception{
+    public void testPingPong() throws Exception {
         mClusterWS.connect();
         Thread.sleep(1900);
-        assertEquals("Websocket disconnected", WebSocket.READYSTATE.OPEN,mClusterWS.getState());
+        assertEquals("Websocket disconnected", WebSocket.READYSTATE.OPEN, mClusterWS.getState());
     }
 
     @Test(expected = NullPointerException.class)
-    public void testNullUrl() throws Exception{
+    public void testNullUrl() throws Exception {
         mClusterWS = new ClusterWS(null);
     }