[hornetq-commits] JBoss hornetq SVN: r9963 - trunk/tests/src/org/hornetq/tests/util.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2010-12-01 09:39:17 -0500 (Wed, 01 Dec 2010)
New Revision: 9963

Modified:
   trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java
   trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java
Log:
moced erroneus thread check

Modified: trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java	2010-12-01 14:32:21 UTC (rev 9962)
+++ trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java	2010-12-01 14:39:17 UTC (rev 9963)
@@ -98,20 +98,6 @@
       {
          System.exit(0);
       }
-      Map<Thread, StackTraceElement[]> threadMap  = Thread.getAllStackTraces();
-      for (Thread thread : threadMap.keySet())
-      {
-         StackTraceElement[] stack = threadMap.get(thread);
-         for (StackTraceElement stackTraceElement : stack)
-         {
-            if(stackTraceElement.getMethodName().contains("getConnectionWithRetry"))
-            {
-               System.out.println(this.getName() + " has left threads running");
-               fail("test left serverlocator running, this could effect other tests");
-               //System.exit(0);
-            }
-         }
-      }
    }
 
    protected static Map<String, Object> generateParams(final int node, final boolean netty)

Modified: trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java	2010-12-01 14:32:21 UTC (rev 9962)
+++ trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java	2010-12-01 14:39:17 UTC (rev 9963)
@@ -776,21 +776,21 @@
          Assert.fail("test did not close all its files " + AsynchronousFileImpl.getTotalMaxIO());
       }
 
-      /*Map<Thread, StackTraceElement[]> threads = Thread.getAllStackTraces();
-      for (Thread thread : threads.keySet())
+
+      Map<Thread, StackTraceElement[]> threadMap  = Thread.getAllStackTraces();
+      for (Thread thread : threadMap.keySet())
       {
-         if(thread.isAlive())
+         StackTraceElement[] stack = threadMap.get(thread);
+         for (StackTraceElement stackTraceElement : stack)
          {
-            StackTraceElement[] elements = threads.get(thread);
-            for (StackTraceElement element : elements)
+            if(stackTraceElement.getMethodName().contains("getConnectionWithRetry"))
             {
-               if(element.getMethodName().contains("getConnectionWithRetry"))
-               {
-                  System.out.println("UnitTestCase.tearDown");
-               }
+               System.out.println(this.getName() + " has left threads running");
+               fail("test left serverlocator running, this could effect other tests");
+               //System.exit(0);
             }
          }
-      }*/
+      }
       super.tearDown();
    }