Uses of Interface
org.apache.activemq.artemis.core.paging.cursor.PagePosition
Packages that use PagePosition
Package
Description
-
Uses of PagePosition in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that return PagePosition -
Uses of PagePosition in org.apache.activemq.artemis.core.paging.cursor
Methods in org.apache.activemq.artemis.core.paging.cursor that return PagePositionModifier and TypeMethodDescriptionPagedReference.getPosition()PagedReferenceImpl.getPosition()This will create a new PagePosition, or return one previously created.Methods in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagePositionModifier and TypeMethodDescriptionvoidPageSubscription.bookmark(PagePosition position) voidPageSubscription.confirmPosition(PagePosition ref) voidPageSubscription.confirmPosition(Transaction tx, PagePosition position, boolean fromDelivery) voidPageSubscription.lateDeliveryRollback(PagePosition position) voidPageSubscription.positionIgnored(PagePosition position) To be called when the cursor decided to ignore a position.PageSubscription.queryMessage(PagePosition pos) To be used to requery the referencevoidPageSubscription.reloadACK(PagePosition position) booleanPageSubscription.reloadPageCompletion(PagePosition position) voidPageSubscription.reloadPreparedACK(Transaction tx, PagePosition position) To be used to avoid a redelivery of a prepared ACK after loadMethod parameters in org.apache.activemq.artemis.core.paging.cursor with type arguments of type PagePositionModifier and TypeMethodDescriptionvoidConsumedPage.forEachAck(BiConsumer<Integer, PagePosition> ackConsumer) Constructors in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagePositionModifierConstructorDescriptionQueryPagedReferenceImpl(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 PagePositionMethods in org.apache.activemq.artemis.core.paging.cursor.impl that return PagePositionModifier and TypeMethodDescriptionPageSubscriptionImpl.PageCursorInfo.getCompleteInfo()PageSubscriptionImpl.PageCursorInfo.getCompletePageInformation()Methods in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type PagePositionModifier and TypeMethodDescriptionvoidPageSubscriptionImpl.PageCursorInfo.addACK(PagePosition posACK) voidPageSubscriptionImpl.bookmark(PagePosition position) intPagePositionImpl.compareTo(PagePosition o) voidPageSubscriptionImpl.confirmPosition(PagePosition position) voidPageSubscriptionImpl.confirmPosition(Transaction tx, PagePosition position, boolean fromDelivery) voidPageSubscriptionImpl.lateDeliveryRollback(PagePosition position) voidPageSubscriptionImpl.PageCursorInfo.loadACK(PagePosition posACK) voidPageSubscriptionImpl.positionIgnored(PagePosition position) PageSubscriptionImpl.queryMessage(PagePosition pos) voidPageSubscriptionImpl.reloadACK(PagePosition position) Theres no need to synchronize this method as it's only called from journal load on startupbooleanPageSubscriptionImpl.reloadPageCompletion(PagePosition position) A page marked as complete will be ignored until it's cleared.voidPageSubscriptionImpl.reloadPreparedACK(Transaction tx, PagePosition position) voidPageSubscriptionImpl.PageCursorInfo.setCompleteInfo(PagePosition completePage) Method parameters in org.apache.activemq.artemis.core.paging.cursor.impl with type arguments of type PagePositionModifier and TypeMethodDescriptionvoidPageSubscriptionImpl.PageCursorInfo.forEachAck(BiConsumer<Integer, PagePosition> ackConsumer) -
Uses of PagePosition in org.apache.activemq.artemis.core.paging.impl
Methods in org.apache.activemq.artemis.core.paging.impl that return PagePosition -
Uses of PagePosition in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence with parameters of type PagePositionModifier and TypeMethodDescriptionvoidStorageManager.storeCursorAcknowledge(long queueID, PagePosition position) voidStorageManager.storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position) voidStorageManager.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 PagePositionModifier and TypeMethodDescriptionvoidAbstractJournalStorageManager.storeCursorAcknowledge(long queueID, PagePosition position) voidAbstractJournalStorageManager.storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position) voidAbstractJournalStorageManager.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 PagePositionConstructors in org.apache.activemq.artemis.core.persistence.impl.journal.codec with parameters of type PagePosition -
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 PagePositionModifier and TypeMethodDescriptionvoidNullStorageManager.storeCursorAcknowledge(long queueID, PagePosition position) voidNullStorageManager.storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position) voidNullStorageManager.storePageCompleteTransactional(long txID, long queueID, PagePosition position)