Author: clebert.suconic(a)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()); }