public abstract class AbstractQueueManager extends Object implements QueueManager, QueueProvider, QueueStoreCacheListener, MuleContextAware, Initialisable, Disposable
Modifier and Type | Field and Description |
---|---|
protected Log |
logger |
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
AbstractQueueManager() |
Modifier and Type | Method and Description |
---|---|
protected void |
clearQueueConfiguration(String queueName) |
void |
closeQueueStore(QueueStore queueStore) |
protected abstract QueueStore |
createQueueStore(String name,
QueueConfiguration config)
Creates a QueueStore
|
void |
dispose()
A lifecycle method where implementor should free up any resources.
|
void |
disposeQueueStore(QueueStore queueStore) |
protected abstract void |
doDispose()
Dispose resources allocated by the implementations.
|
protected MuleContext |
getMuleContext() |
QueueStore |
getQueue(String queueName) |
void |
setDefaultQueueConfiguration(QueueConfiguration config)
Sets the default
QueueConfiguration for any created Queue for
which a custom configuration hasn't been specified |
void |
setMuleContext(MuleContext context) |
void |
setQueueConfiguration(String queueName,
QueueConfiguration newConfig)
Specifies a
QueueConfiguration for the queue which name matches
queueName |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getQueueSession
getRecoveryQueue
initialise
protected transient Log logger
public void setDefaultQueueConfiguration(QueueConfiguration config)
QueueConfiguration
for any created Queue
for
which a custom configuration hasn't been specifiedsetDefaultQueueConfiguration
in interface QueueManager
config
- an instance of QueueConfiguration
public void setQueueConfiguration(String queueName, QueueConfiguration newConfig)
QueueConfiguration
for the queue which name matches
queueNamesetQueueConfiguration
in interface QueueManager
queueName
- the name of a Queue
newConfig
- an instance of QueueConfiguration
public void setMuleContext(MuleContext context)
setMuleContext
in interface MuleContextAware
protected MuleContext getMuleContext()
public final void dispose()
Disposable
dispose
in interface Disposable
public void disposeQueueStore(QueueStore queueStore)
disposeQueueStore
in interface QueueStoreCacheListener
queueStore
- queue to be disposedpublic void closeQueueStore(QueueStore queueStore)
closeQueueStore
in interface QueueStoreCacheListener
queueStore
- queue to be closed.public QueueStore getQueue(String queueName)
getQueue
in interface QueueProvider
queueName
- queue nameprotected void clearQueueConfiguration(String queueName)
protected abstract QueueStore createQueueStore(String name, QueueConfiguration config)
name
- queue nameconfig
- configuration for the queueprotected abstract void doDispose()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.