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

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

Modifier and Type	Class and Description
class	PageSubscriptionImpl

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() Deprecated.

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)
void	ActiveMQServerLogger_$logger.timedOutFlushingExecutorsPagingCursor(PageSubscription pageSubscription)

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 and Description
protected PageSubscription	QueueImpl.pageSubscription

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

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

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, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, SimpleString lastValueKey, Boolean nonDestructive, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) Deprecated.
LastValueQueue(QueueConfiguration queueConfiguration, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) Deprecated.
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, Long ringSize, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) Deprecated.
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) Deprecated.
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, 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) Deprecated.
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, 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) Deprecated.
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, 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) Deprecated.
QueueImpl(QueueConfiguration queueConfiguration, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)