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