[jboss-cvs] JBossAS SVN: r60167 - trunk/testsuite/src/main/org/jboss/test/jbossmessaging/test.

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

Author: clebert.suconic at jboss.com
Date: 2007-02-01 15:09:34 -0500 (Thu, 01 Feb 2007)
New Revision: 60167

Modified:
   trunk/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java
Log:
Removing clause that was causing timeout and using an assertion to avoid a forever wait

Modified: trunk/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java
===================================================================
--- trunk/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java	2007-02-01 19:20:46 UTC (rev 60166)
+++ trunk/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java	2007-02-01 20:09:34 UTC (rev 60167)
@@ -349,7 +349,9 @@
       synchronized (listener)
       {
          if (listener.i < iterationCount)
-            listener.wait();
+            listener.wait(5000);
+         
+         assertEquals(iterationCount, listener.i);
       }
       sendThread.join();
       topicConnection.close();
@@ -418,9 +420,14 @@
       sendSynchMessage();
       synchronized (listener)
       {
+    	 System.out.println("Hello");
          if (listener.i < iterationCount)
-            listener.wait();
+         {
+            listener.wait(5000);
+         }
+         assertEquals(iterationCount, listener.i);
       }
+      
 
       sendThread.join();
       topicDurableConnection.close();
@@ -678,10 +685,11 @@
       {
          synchronized (this)
          {
+        	System.out.println("Listener:: Got message " + i);
             i++;
             log.debug("Got message " + i);
             if (i >= iterationCount)
-               this.notify();
+               this.notifyAll();
          }
       }
    }