[jboss-cvs] JBoss Messaging SVN: r1401 - trunk/tests/src/org/jboss/test/messaging/jms/server/destination

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

Author: clebert.suconic at jboss.com
Date: 2006-09-29 11:35:46 -0400 (Fri, 29 Sep 2006)
New Revision: 1401

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/server/destination/QueueManagementTest.java
Log:
JBMESSAGING-565 - Adding thread.sleep to fix the racing issue and adding debug output to debug the issue

Modified: trunk/tests/src/org/jboss/test/messaging/jms/server/destination/QueueManagementTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/server/destination/QueueManagementTest.java	2006-09-29 15:07:42 UTC (rev 1400)
+++ trunk/tests/src/org/jboss/test/messaging/jms/server/destination/QueueManagementTest.java	2006-09-29 15:35:46 UTC (rev 1401)
@@ -229,6 +229,7 @@
 
    public void testMessageCountOverFullSize() throws Exception
    {
+      log.info("** starting testMessageCountOverFullSize");
       InitialContext ic = new InitialContext(ServerManagement.getJNDIEnvironment());
       ConnectionFactory cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");
       Connection conn = null;
@@ -270,10 +271,14 @@
 
          int receivedCount = 0;
 
+         log.info("Starting receiver loop...");
+
          while((cons.receive(2000)) != null)
          {
             receivedCount++;
 
+            log.info(receivedCount + " messages received");
+            Thread.sleep(500);
             int mc = ((Integer)ServerManagement.
                getAttribute(destObjectName, "MessageCount")).intValue();
 
@@ -291,6 +296,7 @@
       }
       finally
       {
+         log.info("** leaving testMessageCountOverFullSize");
          ServerManagement.undeployQueue("QueueMessageCount2");
 
          if (conn != null)