Author: clebert.suconic(a)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) {