@NoImplement public interface QueueManager extends Startable, Stoppable
PHASE_NAME
PHASE_NAME
Modifier and Type | Method and Description |
---|---|
Optional<QueueConfiguration> |
getQueueConfiguration(String queueName)
Returns the configuration of the
Queue of the given queueName |
QueueSession |
getQueueSession()
Returns a new instance of
QueueSession bounded to this QueueManager |
void |
setDefaultQueueConfiguration(QueueConfiguration config)
Sets the default
QueueConfiguration for any created Queue for which a custom
configuration hasn't been specified |
void |
setQueueConfiguration(String queueName,
QueueConfiguration config)
Specifies a
QueueConfiguration for the queue which name matches queueName |
QueueSession getQueueSession()
QueueSession
bounded to this QueueManager
void setDefaultQueueConfiguration(QueueConfiguration config)
QueueConfiguration
for any created Queue
for which a custom
configuration hasn't been specifiedconfig
- an instance of QueueConfiguration
void setQueueConfiguration(String queueName, QueueConfiguration config)
QueueConfiguration
for the queue which name matches queueNamequeueName
- the name of a Queue
config
- an instance of QueueConfiguration
Optional<QueueConfiguration> getQueueConfiguration(String queueName)
Queue
of the given queueName
queueName
- the name of a configured queueOptional.empty()
if no such queueCopyright © 2018. All rights reserved.