[jboss-cvs] JBoss Messaging SVN: r7543 - trunk/tests/src/org/jboss/messaging/tests/util.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2009-07-08 08:19:26 -0400 (Wed, 08 Jul 2009)
New Revision: 7543

Modified:
   trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java
Log:
check in test fixture that ports used by netty are available before and after the test is run

Modified: trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java	2009-07-08 10:26:57 UTC (rev 7542)
+++ trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java	2009-07-08 12:19:26 UTC (rev 7543)
@@ -35,6 +35,7 @@
 import java.io.OutputStream;
 import java.io.PrintWriter;
 import java.io.StringWriter;
+import java.net.ServerSocket;
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.HashSet;
@@ -230,6 +231,35 @@
       return o;
    }
    
+   protected static void checkFreePort(int... ports)
+   {
+      for (int port : ports)
+      {
+         ServerSocket ssocket = null;
+         try
+         {
+           ssocket = new ServerSocket(port);  
+         }
+         catch (Exception e)
+         {
+            fail("port " + port + " is already bound");
+         }
+         finally
+         {
+            if (ssocket != null)
+            {
+               try
+               {
+                  ssocket.close();
+               }
+               catch (IOException e)
+               {
+               }
+            }
+         }
+      }
+   }
+   
    // Constructors --------------------------------------------------
 
    // Protected -----------------------------------------------------
@@ -507,6 +537,8 @@
       
       InVMRegistry.instance.clear();
       
+      checkFreePort(5445, 5545);
+      
       log.info("###### starting test " + this.getClass().getName() + "." + this.getName());
    }
    
@@ -516,7 +548,9 @@
       deleteDirectory(new File(getTestDir()));
 
       assertEquals(0, InVMRegistry.instance.size());          
-      
+
+      checkFreePort(5445, 5545);
+
       super.tearDown();
    }