[hornetq-commits] JBoss hornetq SVN: r10313 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-03-10 12:56:43 -0500 (Thu, 10 Mar 2011)
New Revision: 10313

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeReconnectTest.java
Log:
format only

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeReconnectTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeReconnectTest.java	2011-03-10 17:03:33 UTC (rev 10312)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeReconnectTest.java	2011-03-10 17:56:43 UTC (rev 10313)
@@ -152,7 +152,6 @@
          server1.start();
          server0.start();
 
-
          BridgeReconnectTest.log.info("** failing connection");
          // Now we will simulate a failure of the bridge connection between server0 and server1
          server0.stop(true);
@@ -165,7 +164,6 @@
 
          ClientSession session0 = csf0.createSession(false, true, true);
 
-
          ClientProducer prod0 = session0.createProducer(testAddress);
 
          ClientSessionFactory csf2 = locator.createSessionFactory(server2tc);
@@ -210,13 +208,11 @@
          service2.stop();
       }
 
-
       Assert.assertEquals(0, server0.getRemotingService().getConnections().size());
       Assert.assertEquals(0, server1.getRemotingService().getConnections().size());
       Assert.assertEquals(0, service2.getRemotingService().getConnections().size());
    }
 
-
    // Fail bridge and attempt failover a few times before succeeding
    public void testFailoverAndReconnectAfterAFewTries() throws Exception
    {
@@ -299,7 +295,6 @@
          // Now we will simulate a failure of the bridge connection between server0 and server1
          server0.stop(true);
 
-
          locator = HornetQClient.createServerLocatorWithHA(server2tc);
          locator.setReconnectAttempts(100);
          ClientSessionFactory csf0 = locator.createSessionFactory(server2tc);
@@ -314,7 +309,6 @@
 
          session2.start();
 
-
          final int numMessages = 10;
 
          SimpleString propKey = new SimpleString("propkey");
@@ -349,7 +343,6 @@
          service2.stop();
       }
 
-
       Assert.assertEquals(0, server0.getRemotingService().getConnections().size());
       Assert.assertEquals(0, server1.getRemotingService().getConnections().size());
       Assert.assertEquals(0, service2.getRemotingService().getConnections().size());
@@ -480,7 +473,6 @@
          server1.stop();
       }
 
-
       Assert.assertEquals(0, server0.getRemotingService().getConnections().size());
       Assert.assertEquals(0, server1.getRemotingService().getConnections().size());
    }
@@ -629,7 +621,6 @@
          server1.stop();
       }
 
-
       Assert.assertEquals(0, server0.getRemotingService().getConnections().size());
       Assert.assertEquals(0, server1.getRemotingService().getConnections().size());
    }
@@ -774,7 +765,6 @@
          server1.stop();
       }
 
-
       Assert.assertEquals(0, server0.getRemotingService().getConnections().size());
       Assert.assertEquals(0, server1.getRemotingService().getConnections().size());
    }