[jboss-cvs] JBoss Messaging SVN: r4199 - in trunk: tests/src/org/jboss/messaging/tests/integration and 1 other directory.

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

Author: timfox
Date: 2008-05-14 15:29:57 -0400 (Wed, 14 May 2008)
New Revision: 4199

Modified:
   trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java
   trunk/tests/src/org/jboss/messaging/tests/integration/CoreClientTest.java
Log:
Oops added back deleted lines


Modified: trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java	2008-05-14 19:00:38 UTC (rev 4198)
+++ trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java	2008-05-14 19:29:57 UTC (rev 4199)
@@ -43,6 +43,7 @@
 import org.jboss.messaging.core.server.HandleStatus;
 import org.jboss.messaging.core.server.MessageReference;
 import org.jboss.messaging.core.server.Queue;
+import org.jboss.messaging.core.server.ServerMessage;
 import org.jboss.messaging.core.transaction.Transaction;
 import org.jboss.messaging.core.transaction.impl.TransactionImpl;
 import org.jboss.messaging.util.SimpleString;
@@ -170,7 +171,7 @@
 
       deliver();
    }
-
+ 
    /*
     * Attempt to deliver all the messages in the queue
     * 
@@ -530,11 +531,11 @@
       {
          if (first)
          {
-       //     messageReferences.addFirst(ref, ref.getMessage().getPriority());
+            messageReferences.addFirst(ref, ref.getMessage().getPriority());
          }
          else
          {
-      //      messageReferences.addLast(ref, ref.getMessage().getPriority());
+            messageReferences.addLast(ref, ref.getMessage().getPriority());
          }
 
          if (!direct && promptDelivery)

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/CoreClientTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/CoreClientTest.java	2008-05-14 19:00:38 UTC (rev 4198)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/CoreClientTest.java	2008-05-14 19:29:57 UTC (rev 4199)
@@ -131,7 +131,7 @@
             
       final CountDownLatch latch = new CountDownLatch(1);
 //      
-      final int numMessages = 50000;
+      final int numMessages = 100000000;
       
       class MyHandler implements MessageHandler
       {