[jboss-cvs] JBoss Messaging SVN: r5217 - branches/Branch_JBMESSAGING_1416/tests/src/org/jboss/test/messaging/jms.

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

Author: gaohoward
Date: 2008-10-30 03:36:33 -0400 (Thu, 30 Oct 2008)
New Revision: 5217

Modified:
   branches/Branch_JBMESSAGING_1416/tests/src/org/jboss/test/messaging/jms/OrderingGroupConnectionConsumerTest.java
Log:
JBMESSAGING-1416


Modified: branches/Branch_JBMESSAGING_1416/tests/src/org/jboss/test/messaging/jms/OrderingGroupConnectionConsumerTest.java
===================================================================
--- branches/Branch_JBMESSAGING_1416/tests/src/org/jboss/test/messaging/jms/OrderingGroupConnectionConsumerTest.java	2008-10-30 07:11:17 UTC (rev 5216)
+++ branches/Branch_JBMESSAGING_1416/tests/src/org/jboss/test/messaging/jms/OrderingGroupConnectionConsumerTest.java	2008-10-30 07:36:33 UTC (rev 5217)
@@ -133,13 +133,8 @@
          }
          
          //allow consumer thread gracefully shutdown
-         try
-         {
-            Thread.sleep(3000);
-         }
-         catch (InterruptedException e)
-         {
-         }
+         doze(3000);
+         
          cc.close();
 
          consumerConn.close();
@@ -156,11 +151,25 @@
    }
    
    
+   /**
+    * @param i
+    */
+   private void doze(long nt)
+   {
+      try
+      {
+         Thread.sleep(nt);
+      }
+      catch (InterruptedException e)
+      {
+      }
+   }
+
    /*
     * Make sure the ordering group messages are received in order
     * thru a ConnectionConsumer in transaction mode.
     */
-   /*
+
    public void testTransactedReceive() throws Exception
    {
       if (ServerManagement.isRemote()) return;
@@ -212,7 +221,7 @@
             assertEquals(txm.getText(), "testing" + i);
          }
 
-         checkEmpty(queue1);
+         doze(3000);
          
          cc.close();
 
@@ -228,7 +237,7 @@
          
       }
    }
-*/
+
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------
@@ -279,21 +288,16 @@
       {
          try
          {
-            System.err.println("===== ======= ======== ==========  coutner: " + counter);
             //roll back once for every 5 messages
             if (counter%5 == 0) {
-               System.err.println("===== ======= ======== ==========  rolling back : " + ((TextMessage)message).getText());
                sessRef.rollback();
             }
             else
             {
-              System.err.println("===== ======= ======== ========== received : " + ((TextMessage)message).getText());
               owner.addReceived((TextMessage)message);
-              System.err.println("===== ======= ======== ========== commiting : " + ((TextMessage)message).getText());
               sessRef.commit();
             }
             counter++;
-            System.err.println("===coutner: " + counter);
          }
          catch (Exception e)
          {