[hornetq-commits] JBoss hornetq SVN: r8294 - trunk/tests/src/org/hornetq/tests/integration/remoting.

[do-not-reply at jboss.org]

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