[jboss-cvs] JBoss Messaging SVN: r5650 - in branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging: impl and 1 other directory.

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

Author: clebert.suconic at jboss.com
Date: 2009-01-16 00:58:07 -0500 (Fri, 16 Jan 2009)
New Revision: 5650

Modified:
   branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/PagingStore.java
   branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java
Log:
tweaks

Modified: branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/PagingStore.java
===================================================================
--- branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/PagingStore.java	2009-01-16 05:34:53 UTC (rev 5649)
+++ branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/PagingStore.java	2009-01-16 05:58:07 UTC (rev 5650)
@@ -63,7 +63,7 @@
 
    boolean page(PagedMessage message, boolean sync, boolean duplicateDetection) throws Exception;
    
-   public void readPage() throws Exception;
+   public boolean readPage() throws Exception;
 
    /**
     * 

Modified: branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java
===================================================================
--- branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java	2009-01-16 05:34:53 UTC (rev 5649)
+++ branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java	2009-01-16 05:58:07 UTC (rev 5650)
@@ -646,13 +646,13 @@
     * @return
     * @throws Exception
     */
-   public void readPage() throws Exception
+   public boolean readPage() throws Exception
    {
       Page page = depage();
 
       if (page == null)
       {
-         return;
+         return false;
       }
 
       page.open();
@@ -662,6 +662,8 @@
       onDepage(page.getPageId(), storeName, messages);
 
       page.delete();
+      
+      return true;
 
    }