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 and 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 PageSubscription in org.apache.activemq.artemis.core.paging.cursor

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

Modifier and Type	Method and 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 and Description
void	PageCursorProvider.close(PageSubscription pageCursorImpl)
PagedReference	PageCursorProvider.newReference(PagePosition pos, PagedMessage msg, PageSubscription sub)

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

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

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

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

Modifier and Type	Method and 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 and Description
void	PageCursorProviderImpl.close(PageSubscription cursor)
PagedReference	PageCursorProviderImpl.newReference(PagePosition pos, PagedMessage msg, PageSubscription subscription)

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

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

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

Constructor and Description
PageSubscriptionCounterImpl(StorageManager storage, PageSubscription subscription, Executor executor, boolean persistent, long subscriptionID)

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 and Description
boolean	PageTransactionInfoImpl.deliverAfterCommit(PageIterator iterator, PageSubscription cursor, PagePosition cursorPos)

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 and Description
PageSubscription	Queue.getPageSubscription()
PageSubscription	QueueConfig.pageSubscription()

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

Modifier and Type	Method and Description
Queue	QueueFactory.createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated) Deprecated. Replaced by QueueFactory.createQueueWith(org.apache.activemq.artemis.core.server.QueueConfig)
void	ActiveMQServerLogger.timedOutFlushingExecutorsPagingCursor(PageSubscription pageSubscription)

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

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

Modifier and Type	Method and Description
PageSubscription	QueueImpl.getPageSubscription()

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

Modifier and Type	Method and Description
Queue	QueueFactoryImpl.createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated) Deprecated.

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

Constructor and Description
LastValueQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean purgeOnNoConsumers, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean purgeOnNoConsumers, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)