[hornetq-commits] JBoss hornetq SVN: r8294 - trunk/tests/src/org/hornetq/tests/integration/remoting.
Author: clebert.suconic(a)jboss.com
Date: 2009-11-16 19:09:21 -0500 (Mon, 16 Nov 2009)
New Revision: 8294
Modified:
trunk/tests/src/org/hornetq/tests/integration/remoting/ReconnectTest.java
Log:
just tweaks / formatting
Modified: trunk/tests/src/org/hornetq/tests/integration/remoting/ReconnectTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/remoting/ReconnectTest.java 2009-11-17
00:08:14 UTC (rev 8293)
+++ trunk/tests/src/org/hornetq/tests/integration/remoting/ReconnectTest.java 2009-11-17
00:09:21 UTC (rev 8294)
@@ -44,33 +44,31 @@
// Constructors --------------------------------------------------
// Public --------------------------------------------------------
-
-
+
// This is a hack to remove this test from the testsuite
// Remove this method to enable this Test on the testsuite.
// You can still run tests individually on eclipse, but not on the testsuite
public static TestSuite suite()
{
TestSuite suite = new TestSuite();
-
+
// System.out -> JUnit report
System.out.println("Test ReconnectTest being ignored for now!");
-
+
return suite;
}
-
-
+
public void testReconnectNetty() throws Exception
{
internalTestReconnect(true);
}
-
+
public void testReconnectInVM() throws Exception
{
internalTestReconnect(false);
}
- public void internalTestReconnect(boolean isNetty) throws Exception
+ public void internalTestReconnect(final boolean isNetty) throws Exception
{
HornetQServer server = createServer(false, isNetty);
@@ -78,7 +76,7 @@
server.start();
ClientSessionInternal session = null;
-
+
try
{
@@ -93,35 +91,35 @@
session = (ClientSessionInternal)factory.createSession();
final AtomicInteger count = new AtomicInteger(0);
-
+
final CountDownLatch latch = new CountDownLatch(1);
-
+
session.getConnection().addFailureListener(new FailureListener()
{
- public void connectionFailed(HornetQException me)
+ public void connectionFailed(final HornetQException me)
{
count.incrementAndGet();
latch.countDown();
}
-
+
});
-
+
server.stop();
-
+
// I couldn't find a way to install a latch here as I couldn't just use
the FailureListener
// as the FailureListener won't be informed until the reconnection process
is done.
Thread.sleep(2100);
-
+
server.start();
-
+
latch.await();
// Some process to let the Failure listener loop occur
Thread.sleep(500);
-
+
assertEquals(1, count.get());
-
+
}
finally
{
@@ -132,7 +130,7 @@
catch (Throwable e)
{
}
-
+
server.stop();
}