public class TransactionalQueueManager extends AbstractQueueManager
logger
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
TransactionalQueueManager() |
Modifier and Type | Method and Description |
---|---|
protected DefaultQueueStore |
createQueueStore(String name,
QueueConfiguration config)
Creates a QueueStore
|
protected void |
doDispose()
Dispose resources allocated by the implementations.
|
QueueSession |
getQueueSession()
Returns a new instance of
QueueSession bounded to this
QueueManager |
RecoverableQueueStore |
getRecoveryQueue(String queueName) |
void |
initialise()
Method used to perform any initialisation work.
|
void |
start() |
void |
stop() |
clearQueueConfiguration, closeQueueStore, dispose, disposeQueueStore, getMuleContext, getQueue, setDefaultQueueConfiguration, setMuleContext, setQueueConfiguration
public QueueSession getQueueSession()
QueueSession
bounded to this
QueueManager
TransactionalQueueSession
protected DefaultQueueStore createQueueStore(String name, QueueConfiguration config)
AbstractQueueManager
createQueueStore
in class AbstractQueueManager
name
- queue nameconfig
- configuration for the queueprotected void doDispose()
AbstractQueueManager
doDispose
in class AbstractQueueManager
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered frompublic RecoverableQueueStore getRecoveryQueue(String queueName)
queueName
- queue namepublic void start() throws MuleException
MuleException
public void stop() throws MuleException
MuleException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.