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

Packages that use PageSubscription

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.server
org.apache.activemq.artemis.core.server.impl

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

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

Modifier and Type	Method	Description
boolean	PageTransactionInfo.deliverAfterCommit(PageIterator pageIterator, PageSubscription cursor, PagedReference pagedMessage)	This method will hold the position to be delivered later in case this transaction is pending.
void	PagingStore.pageFull(PageSubscription subscription)	Callback to be used by a counter when the Page is full for that counter

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

Fields in org.apache.activemq.artemis.core.paging.cursor declared as PageSubscription

Modifier and Type	Field	Description
protected final PageSubscription	PagedReferenceImpl.subscription

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

Modifier and Type	Method	Description
PageSubscription	PageCursorProvider.createSubscription(long queueId, Filter filter, boolean durable)
PageSubscription	PageCursorProvider.getSubscription(long queueId)

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

Modifier and Type	Method	Description
void	PageCursorProvider.close(PageSubscription pageCursorImpl)
PagedReference	PageCursorProvider.newReference(PagedMessage msg, PageSubscription sub)
PageSubscriptionCounter	PageSubscriptionCounter.setSubscription(PageSubscription subscription)

Method parameters in org.apache.activemq.artemis.core.paging.cursor with type arguments of type PageSubscription

Modifier and Type	Method	Description
void	PageCursorProvider.forEachSubscription(Consumer<PageSubscription> consumer)

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

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

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

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

Modifier and Type	Class	Description
final class	PageSubscriptionImpl

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

Modifier and Type	Method	Description
PageSubscription	PageCursorProviderImpl.createSubscription(long cursorID, Filter filter, boolean persistent)
PageSubscription	PageCursorProviderImpl.getSubscription(long cursorID)

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

Modifier and Type	Method	Description
void	PageCursorProviderImpl.close(PageSubscription cursor)
PagedReference	PageCursorProviderImpl.newReference(PagedMessage msg, PageSubscription subscription)
PageSubscriptionCounter	PageSubscriptionCounterImpl.setSubscription(PageSubscription subscription)

Method parameters in org.apache.activemq.artemis.core.paging.cursor.impl with type arguments of type PageSubscription

Modifier and Type	Method	Description
protected void	PageCursorProviderImpl.cleanupComplete(List<PageSubscription> cursorList)
void	PageCursorProviderImpl.forEachSubscription(Consumer<PageSubscription> consumer)
protected void	PageCursorProviderImpl.storeBookmark(List<PageSubscription> cursorList, Page currentPage)

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

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

Modifier and Type	Method	Description
boolean	PageTransactionInfoImpl.deliverAfterCommit(PageIterator iterator, PageSubscription cursor, PagedReference pagedReference)
void	PagingStoreImpl.pageFull(PageSubscription subscription)

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

Methods in org.apache.activemq.artemis.core.server that return PageSubscription

Modifier and Type	Method	Description
PageSubscription	Queue.getPageSubscription()
PageSubscription	QueueConfig.pageSubscription()	Deprecated.

Uses of PageSubscription in org.apache.activemq.artemis.core.server.impl

Fields in org.apache.activemq.artemis.core.server.impl declared as PageSubscription

Modifier and Type	Field	Description
protected final PageSubscription	QueueImpl.pageSubscription

Methods in org.apache.activemq.artemis.core.server.impl that return PageSubscription

Modifier and Type	Method	Description
static PageSubscription	QueueFactoryImpl.getPageSubscription(QueueConfiguration queueConfiguration, PagingManager pagingManager, Filter filter)
PageSubscription	QueueImpl.getPageSubscription()

Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type PageSubscription

Modifier	Constructor	Description
	LastValueQueue(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
	QueueImpl(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)