Uses of Interface
org.apache.activemq.artemis.core.paging.cursor.PagePosition

Packages that use PagePosition

Package	Description
org.apache.activemq.artemis.core.paging
org.apache.activemq.artemis.core.paging.cursor
org.apache.activemq.artemis.core.paging.cursor.impl
org.apache.activemq.artemis.core.paging.impl
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.impl.journal
org.apache.activemq.artemis.core.persistence.impl.journal.codec
org.apache.activemq.artemis.core.persistence.impl.nullpm
org.apache.activemq.artemis.core.server

Uses of PagePosition in org.apache.activemq.artemis.core.paging

Methods in org.apache.activemq.artemis.core.paging with parameters of type PagePosition

Modifier and Type	Method	Description
boolean	PageTransactionInfo.deliverAfterCommit(PageIterator pageIterator, PageSubscription cursor, PagePosition cursorPos)	This method will hold the position to be delivered later in case this transaction is pending.

Uses of PagePosition in org.apache.activemq.artemis.core.paging.cursor

Methods in org.apache.activemq.artemis.core.paging.cursor that return PagePosition

Modifier and Type	Method	Description
PagePosition	PagedReference.getPosition()
PagePosition	PagedReferenceImpl.getPosition()
PagePosition	PagePosition.nextPage()

Methods in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagePosition

Modifier and Type	Method	Description
void	PageSubscription.addPendingDelivery(PagePosition position)
void	PageSubscription.bookmark(PagePosition position)
void	PageSubscription.confirmPosition(PagePosition ref)
void	PageSubscription.confirmPosition(Transaction tx, PagePosition position)
PagedMessage	PageCache.getMessage(PagePosition pagePosition)
PagedMessage	PageCursorProvider.getMessage(PagePosition pos)
void	PageSubscription.lateDeliveryRollback(PagePosition position)
PagedReference	PageCursorProvider.newReference(PagePosition pos, PagedMessage msg, PageSubscription sub)
void	PageSubscription.positionIgnored(PagePosition position)	To be called when the cursor decided to ignore a position.
PagedMessage	PageSubscription.queryMessage(PagePosition pos)	To be used to requery the reference case the Garbage Collection removed it from the PagedReference as it's using WeakReferences
void	PageIterator.redeliver(PagePosition reference)
void	PageSubscription.redeliver(PageIterator iterator, PagePosition position)	To be used on redeliveries
void	PageSubscription.reloadACK(PagePosition position)
boolean	PageSubscription.reloadPageCompletion(PagePosition position)
void	PageSubscription.reloadPreparedACK(Transaction tx, PagePosition position)	To be used to avoid a redelivery of a prepared ACK after load
void	PageSubscription.removePendingDelivery(PagePosition position)

Constructors in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagePosition

Constructor	Description
PagedReferenceImpl(PagePosition position, PagedMessage message, PageSubscription subscription)

Uses of PagePosition in org.apache.activemq.artemis.core.paging.cursor.impl

Classes in org.apache.activemq.artemis.core.paging.cursor.impl that implement PagePosition

Modifier and Type	Class	Description
class	PagePositionImpl

Methods in org.apache.activemq.artemis.core.paging.cursor.impl that return PagePosition

Modifier and Type	Method	Description
PagePosition	PageSubscriptionImpl.PageCursorInfo.getCompleteInfo()
PagePosition	PagePositionImpl.nextPage()

Methods in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type PagePosition

Modifier and Type	Method	Description
void	PageSubscriptionImpl.PageCursorInfo.addACK(PagePosition posACK)
void	PageSubscriptionImpl.addPendingDelivery(PagePosition position)
void	PageSubscriptionImpl.bookmark(PagePosition position)
int	PagePositionImpl.compareTo(PagePosition o)
void	PageSubscriptionImpl.confirmPosition(PagePosition position)
void	PageSubscriptionImpl.confirmPosition(Transaction tx, PagePosition position)
PagedMessage	LivePageCacheImpl.getMessage(PagePosition pagePosition)
PagedMessage	PageCursorProviderImpl.getMessage(PagePosition pos)
PagedMessage	PageReader.getMessage(PagePosition pagePosition)
PagedMessage	PageReader.getMessage(PagePosition pagePosition, boolean throwException, boolean keepOpen)
boolean	PageSubscriptionImpl.PageCursorInfo.isAck(PagePosition position)
boolean	PageSubscriptionImpl.PageCursorInfo.isRemoved(PagePosition pos)
void	PageSubscriptionImpl.lateDeliveryRollback(PagePosition position)
void	PageSubscriptionImpl.PageCursorInfo.loadACK(PagePosition posACK)
PagedReference	PageCursorProviderImpl.newReference(PagePosition pos, PagedMessage msg, PageSubscription subscription)
void	PageSubscriptionImpl.positionIgnored(PagePosition position)
PagedMessage	PageSubscriptionImpl.queryMessage(PagePosition pos)
void	PageSubscriptionImpl.redeliver(PageIterator iterator, PagePosition position)
void	PageSubscriptionImpl.reloadACK(PagePosition position)	Theres no need to synchronize this method as it's only called from journal load on startup
boolean	PageSubscriptionImpl.reloadPageCompletion(PagePosition position)	A page marked as complete will be ignored until it's cleared.
void	PageSubscriptionImpl.reloadPreparedACK(Transaction tx, PagePosition position)
void	PageSubscriptionImpl.PageCursorInfo.remove(PagePosition position)
void	PageSubscriptionImpl.removePendingDelivery(PagePosition position)
void	PageSubscriptionImpl.PageCursorInfo.setCompleteInfo(PagePosition completePage)

Uses of PagePosition in org.apache.activemq.artemis.core.paging.impl

Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type PagePosition

Modifier and Type	Method	Description
boolean	PageTransactionInfoImpl.deliverAfterCommit(PageIterator iterator, PageSubscription cursor, PagePosition cursorPos)

Uses of PagePosition in org.apache.activemq.artemis.core.persistence

Methods in org.apache.activemq.artemis.core.persistence with parameters of type PagePosition

Modifier and Type	Method	Description
void	StorageManager.storeCursorAcknowledge(long queueID, PagePosition position)
void	StorageManager.storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position)
void	StorageManager.storePageCompleteTransactional(long txID, long queueID, PagePosition position)

Uses of PagePosition in org.apache.activemq.artemis.core.persistence.impl.journal

Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type PagePosition

Modifier and Type	Method	Description
void	AbstractJournalStorageManager.storeCursorAcknowledge(long queueID, PagePosition position)
void	AbstractJournalStorageManager.storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position)
void	AbstractJournalStorageManager.storePageCompleteTransactional(long txID, long queueID, PagePosition position)

Uses of PagePosition in org.apache.activemq.artemis.core.persistence.impl.journal.codec

Fields in org.apache.activemq.artemis.core.persistence.impl.journal.codec declared as PagePosition

Modifier and Type	Field	Description
PagePosition	CursorAckRecordEncoding.position

Constructors in org.apache.activemq.artemis.core.persistence.impl.journal.codec with parameters of type PagePosition

Constructor	Description
CursorAckRecordEncoding(long queueID, PagePosition position)

Uses of PagePosition in org.apache.activemq.artemis.core.persistence.impl.nullpm

Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type PagePosition

Modifier and Type	Method	Description
void	NullStorageManager.storeCursorAcknowledge(long queueID, PagePosition position)
void	NullStorageManager.storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position)
void	NullStorageManager.storePageCompleteTransactional(long txID, long queueID, PagePosition position)

Uses of PagePosition in org.apache.activemq.artemis.core.server

Methods in org.apache.activemq.artemis.core.server with parameters of type PagePosition

Modifier and Type	Method	Description
void	ActiveMQServerLogger_$logger.pageNotFound(PagePosition pos, long queueID, String queue)
void	ActiveMQServerLogger.pageNotFound(PagePosition pos, long queueID, String queue)
void	ActiveMQServerLogger_$logger.pageSubscriptionCouldntLoad(long transactionID, PagePosition position, SimpleString address, SimpleString name)
void	ActiveMQServerLogger.pageSubscriptionCouldntLoad(long transactionID, PagePosition position, SimpleString address, SimpleString name)