[hornetq-commits] JBoss hornetq SVN: r9847 - in branches/Branch_New_Paging: tests/src/org/hornetq/tests/integration/paging and 1 other directory.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-11-04 18:51:35 -0400 (Thu, 04 Nov 2010)
New Revision: 9847

Modified:
   branches/Branch_New_Paging/src/main/org/hornetq/core/server/impl/QueueImpl.java
   branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCursorTest.java
Log:
just a backup

Modified: branches/Branch_New_Paging/src/main/org/hornetq/core/server/impl/QueueImpl.java
===================================================================
--- branches/Branch_New_Paging/src/main/org/hornetq/core/server/impl/QueueImpl.java	2010-11-04 22:47:33 UTC (rev 9846)
+++ branches/Branch_New_Paging/src/main/org/hornetq/core/server/impl/QueueImpl.java	2010-11-04 22:51:35 UTC (rev 9847)
@@ -1249,6 +1249,11 @@
    
    private void depage()
    {
+      if (paused || consumerList.isEmpty())
+      {
+         return;
+      }
+
       int nmessages = 0;
       while (nmessages < MAX_DELIVERIES_IN_LOOP && pageIterator.hasNext())
       {

Modified: branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCursorTest.java
===================================================================
--- branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCursorTest.java	2010-11-04 22:47:33 UTC (rev 9846)
+++ branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCursorTest.java	2010-11-04 22:51:35 UTC (rev 9847)
@@ -1025,6 +1025,7 @@
       try
       {
          queue = server.createQueue(ADDRESS, ADDRESS, null, true, false);
+         queue.pause();
       }
       catch (Exception ignored)
       {