public class QueueFactoryImpl extends Object implements QueueFactory
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 and Description |
---|
QueueFactoryImpl(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
Queue |
createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary) |
void |
setPostOffice(PostOffice postOffice)
This is required for delete-all-reference to work correctly with paging
|
protected final HierarchicalRepository<AddressSettings> addressSettingsRepository
protected final ScheduledExecutorService scheduledExecutor
protected PostOffice postOffice
protected final StorageManager storageManager
protected final ExecutorFactory executorFactory
public QueueFactoryImpl(ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, HierarchicalRepository<AddressSettings> addressSettingsRepository, StorageManager storageManager)
public void setPostOffice(PostOffice postOffice)
QueueFactory
setPostOffice
in interface QueueFactory
public Queue createQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, boolean durable, boolean temporary)
createQueue
in interface QueueFactory
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.