Package org.apache.activemq.artemis.core.server.impl

Class QueueFactoryImpl

java.lang.Object

org.apache.activemq.artemis.core.server.impl.QueueFactoryImpl

All Implemented Interfaces:

QueueFactory

public class QueueFactoryImpl
extends Object
implements QueueFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected final HierarchicalRepository<AddressSettings>	addressSettingsRepository
protected final ExecutorFactory	executorFactory
protected PostOffice	postOffice	This is required for delete-all-reference to work correctly with paging, and controlling global-size
protected final ScheduledExecutorService	scheduledExecutor
protected final ActiveMQServer	server
protected final StorageManager	storageManager

Constructor Summary

Constructors

Constructor	Description
QueueFactoryImpl(ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, HierarchicalRepository<AddressSettings> addressSettingsRepository, StorageManager storageManager, ActiveMQServer server)

Method Summary

Modifier and Type	Method	Description
Queue	createQueueWith(QueueConfiguration config, PagingManager pagingManager, Filter filter)
static PageSubscription	getPageSubscription(QueueConfiguration queueConfiguration, PagingManager pagingManager, Filter filter)
void	queueRemoved(Queue queue)
void	setPostOffice(PostOffice postOffice)	This is required for delete-all-reference to work correctly with paging

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

addressSettingsRepository

protected final HierarchicalRepository<AddressSettings> addressSettingsRepository

scheduledExecutor

protected final ScheduledExecutorService scheduledExecutor

postOffice

protected PostOffice postOffice

This is required for delete-all-reference to work correctly with paging, and controlling global-size

storageManager

protected final StorageManager storageManager

executorFactory

protected final ExecutorFactory executorFactory

server

protected final ActiveMQServer server

Constructor Details

QueueFactoryImpl

public QueueFactoryImpl(ExecutorFactory executorFactory,
 ScheduledExecutorService scheduledExecutor,
 HierarchicalRepository<AddressSettings> addressSettingsRepository,
 StorageManager storageManager,
 ActiveMQServer server)

Method Details

setPostOffice

public void setPostOffice(PostOffice postOffice)

Description copied from interface: QueueFactory

This is required for delete-all-reference to work correctly with paging

Specified by:

setPostOffice in interface QueueFactory

createQueueWith

public Queue createQueueWith(QueueConfiguration config,
 PagingManager pagingManager,
 Filter filter)

Specified by:

createQueueWith in interface QueueFactory

queueRemoved

public void queueRemoved(Queue queue)

Specified by:

queueRemoved in interface QueueFactory

getPageSubscription

public static PageSubscription getPageSubscription(QueueConfiguration queueConfiguration,
 PagingManager pagingManager,
 Filter filter)