Uses of Interface
org.apache.activemq.artemis.utils.actors.ArtemisExecutor

Packages that use ArtemisExecutor

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.impl
org.apache.activemq.artemis.utils
org.apache.activemq.artemis.utils.actors

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

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

Modifier and Type	Method and Description
PageCursorProvider	PagingStoreFactory.newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor)

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

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

Modifier and Type	Method and Description
ArtemisExecutor	PageSubscription.getExecutor()

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

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

Modifier and Type	Method and Description
ArtemisExecutor	PageSubscriptionImpl.getExecutor()

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

Constructor and Description
PageCursorProviderImpl(PagingStore pagingStore, StorageManager storageManager, ArtemisExecutor executor, int maxCacheSize)
PageCursorProviderImpl(PagingStore pagingStore, StorageManager storageManager, ArtemisExecutor executor, int maxCacheSize, boolean readWholePage)

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

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

Modifier and Type	Method and Description
PageCursorProvider	PagingStoreFactoryDatabase.newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor)
PageCursorProvider	PagingStoreFactoryNIO.newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor)

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

Constructor and Description
PagingStoreImpl(SimpleString address, ScheduledExecutorService scheduledExecutor, long syncTimeout, PagingManager pagingManager, StorageManager storageManager, SequentialFileFactory fileFactory, PagingStoreFactory storeFactory, SimpleString storeName, AddressSettings addressSettings, ArtemisExecutor executor, ArtemisExecutor ioExecutor, boolean syncNonTransactional)
PagingStoreImpl(SimpleString address, ScheduledExecutorService scheduledExecutor, long syncTimeout, PagingManager pagingManager, StorageManager storageManager, SequentialFileFactory fileFactory, PagingStoreFactory storeFactory, SimpleString storeName, AddressSettings addressSettings, ArtemisExecutor executor, boolean syncNonTransactional)

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

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

Modifier and Type	Method and Description
ArtemisExecutor	QueueImpl.getExecutor()

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

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(long id, SimpleString address, SimpleString name, Filter filter, 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)

Uses of ArtemisExecutor in org.apache.activemq.artemis.utils

Methods in org.apache.activemq.artemis.utils that return ArtemisExecutor

Modifier and Type	Method and Description
ArtemisExecutor	ExecutorFactory.getExecutor()

Uses of ArtemisExecutor in org.apache.activemq.artemis.utils.actors

Classes in org.apache.activemq.artemis.utils.actors that implement ArtemisExecutor

Modifier and Type	Class and Description
class	OrderedExecutor An executor that always runs all tasks in order, using a delegate executor to run the tasks.

Methods in org.apache.activemq.artemis.utils.actors that return ArtemisExecutor

Modifier and Type	Method and Description
static ArtemisExecutor	ArtemisExecutor.delegate(Executor executor) Artemis is supposed to implement this properly, however in tests or tools this can be used as a fake, doing a simple delegate and using the default methods implemented here.
ArtemisExecutor	OrderedExecutorFactory.getExecutor() Get an executor that always executes tasks in order.