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

A QueueFactoryImpl

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Queue	createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated)
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 Detail

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

Constructor Detail

QueueFactoryImpl

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

Method Detail

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

createQueue

public Queue createQueue(long persistenceID,
                         SimpleString address,
                         SimpleString name,
                         Filter filter,
                         PageSubscription pageSubscription,
                         SimpleString user,
                         boolean durable,
                         boolean temporary,
                         boolean autoCreated)

Specified by:

createQueue in interface QueueFactory