[jboss-cvs] JBossAS SVN: r75164 - branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test.

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

Author: clebert.suconic at jboss.com
Date: 2008-06-27 13:11:20 -0400 (Fri, 27 Jun 2008)
New Revision: 75164

Modified:
   branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java
Log:
Fixing a test timeout

Modified: branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java
===================================================================
--- branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java	2008-06-27 16:16:34 UTC (rev 75163)
+++ branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/UnackedUnitTestCase.java	2008-06-27 17:11:20 UTC (rev 75164)
@@ -119,7 +119,6 @@
       for (int i = 0; i < iterationCount; i++)
          sender.send(message, persistence, 4, 0);
 
-      Thread.sleep(2000); // to let async sends to complete
       session.close();
 
       session = queueConnection.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
@@ -170,7 +169,6 @@
       for (int i = 0; i < iterationCount; i++)
          sender.send(message, persistence, 4, 0);
 
-      Thread.sleep(2000);
       session.close();
 
       QueueSession session1 = queueConnection.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
@@ -191,8 +189,8 @@
 	      
 	      do
 	      {
-	    	  messageConsumer1 = receiver1.receive(1000);
-	    	  messageConsumer2 = receiver2.receive(1000);
+	    	  messageConsumer1 = receiver1.receive(200);
+	    	  messageConsumer2 = receiver2.receive(200);
 	    	  if (messageConsumer1 != null)
 	    	  {
 	    		  c1 ++;
@@ -293,8 +291,8 @@
 	      
 	      do
 	      {
-	    	  messageConsumer1 = receiver1.receive(1000);
-	    	  messageConsumer2 = receiver2.receive(1000);
+	    	  messageConsumer1 = receiver1.receive(200);
+	    	  messageConsumer2 = receiver2.receive(200);
 	    	  if (messageConsumer1 != null)
 	    	  {
 	    		  c1 ++;
@@ -365,9 +363,6 @@
                   }
                   
                   
-                  // allow some time for Non Persistent messages
-                  Thread.sleep(2000); 
-
                   session.close();
                }
                catch (Exception e)
@@ -724,7 +719,6 @@
       Message message = session.createMessage();
       sender.send(message);
 
-      Thread.sleep(1000);
       session.close();
       getLog().debug("Sent Synch Message");
    }