[hornetq-commits] JBoss hornetq SVN: r11952 - trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor.

do-not-reply at jboss.org do-not-reply at jboss.org
Tue Jan 3 06:54:42 EST 2012


Author: borges
Date: 2012-01-03 06:54:41 -0500 (Tue, 03 Jan 2012)
New Revision: 11952

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageSubscription.java
Log:
Fix link in javadoc

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageSubscription.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageSubscription.java	2012-01-03 11:54:28 UTC (rev 11951)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/PageSubscription.java	2012-01-03 11:54:41 UTC (rev 11952)
@@ -34,21 +34,21 @@
    // Cursor query operations --------------------------------------
 
    PagingStore getPagingStore();
-   
+
    // To be called before the server is down
    void stop();
 
    void bookmark(PagePosition position) throws Exception;
-   
+
    PageSubscriptionCounter getCounter();
-   
+
    long getMessageCount();
 
    long getId();
 
    boolean isPersistent();
-   
-   /** Used as a delegate method to pageStore.isPaging() */
+
+   /** Used as a delegate method to {@link PagingStore#isPaging()} */
    boolean isPaging();
 
    public LinkedListIterator<PagedReference> iterator();
@@ -75,7 +75,7 @@
    void confirmPosition(Transaction tx, PagePosition position) throws Exception;
 
    /**
-    * 
+    *
     * @return the first page in use or MAX_LONG if none is in use
     */
    long getFirstPage();
@@ -89,11 +89,11 @@
 
    /**
     * To be called when the cursor decided to ignore a position.
-    * 
+    *
     * @param position
     */
    void positionIgnored(PagePosition position);
-   
+
    void lateDeliveryRollback(PagePosition position);
 
    /**
@@ -105,8 +105,8 @@
    void processReload() throws Exception;
 
    void addPendingDelivery(final PagePosition position);
-   
-   /**      
+
+   /**
     * To be used on redeliveries
     * @param position
     */
@@ -122,11 +122,11 @@
 
    /** wait all the scheduled runnables to finish their current execution */
    void flushExecutors();
-   
+
    void setQueue(Queue queue);
-   
+
    Queue getQueue();
-   
+
    /**
     * To be used to requery the reference case the Garbage Collection removed it from the PagedReference as it's using WeakReferences
     * @param pos



More information about the hornetq-commits mailing list