org.mule.util.queue
Class TransactionalQueueManager
java.lang.Object
org.mule.util.xa.AbstractResourceManager
org.mule.util.xa.AbstractXAResourceManager
org.mule.util.queue.TransactionalQueueManager
- All Implemented Interfaces:
- MuleContextAware, Startable, Stoppable, QueueManager
public class TransactionalQueueManager
- extends AbstractXAResourceManager
- implements QueueManager, MuleContextAware
The Transactional Queue Manager is responsible for creating and Managing
transactional Queues. Queues can also be persistent by setting a persistence
strategy on the manager. Default straties are provided for Memory, Jounaling,
Cache and File.
Fields inherited from class org.mule.util.xa.AbstractResourceManager |
DEFAULT_COMMIT_TIMEOUT_FACTOR, DEFAULT_TIMEOUT_MSECS, defaultTimeout, dirty, globalTransactions, logger, OPERATION_MODE_RECOVERING, OPERATION_MODE_STARTED, OPERATION_MODE_STARTING, OPERATION_MODE_STOPPED, OPERATION_MODE_STOPPING, operationMode, SHUTDOWN_MODE_KILL, SHUTDOWN_MODE_NORMAL, SHUTDOWN_MODE_ROLLBACK |
Methods inherited from class org.mule.util.xa.AbstractResourceManager |
assureReady, assureStarted, beginTransaction, commitTransaction, getDefaultTransactionTimeout, prepareTransaction, rollbackTransaction, setDefaultTransactionTimeout, setDirty, setTransactionRollbackOnly, start, startTransaction, stop, stop, stop, waitForAllTxToStop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
TransactionalQueueManager
public TransactionalQueueManager()
getQueueSession
public QueueSession getQueueSession()
- Specified by:
getQueueSession
in interface QueueManager
setDefaultQueueConfiguration
public void setDefaultQueueConfiguration(QueueConfiguration config)
- Specified by:
setDefaultQueueConfiguration
in interface QueueManager
setQueueConfiguration
public void setQueueConfiguration(String queueName,
QueueConfiguration config)
- Specified by:
setQueueConfiguration
in interface QueueManager
getQueue
protected QueueInfo getQueue(String name)
getQueue
protected QueueInfo getQueue(String name,
QueueConfiguration config)
getQueueInfo
public QueueInfo getQueueInfo(String name)
doStart
protected void doStart()
throws ResourceManagerSystemException
- Overrides:
doStart
in class AbstractResourceManager
- Throws:
ResourceManagerSystemException
shutdown
protected boolean shutdown(int mode,
long timeoutMSecs)
- Overrides:
shutdown
in class AbstractResourceManager
recover
protected void recover()
throws ResourceManagerSystemException
- Overrides:
recover
in class AbstractResourceManager
- Throws:
ResourceManagerSystemException
createTransactionContext
protected AbstractTransactionContext createTransactionContext(Object session)
- Specified by:
createTransactionContext
in class AbstractResourceManager
doBegin
protected void doBegin(AbstractTransactionContext context)
- Specified by:
doBegin
in class AbstractResourceManager
doPrepare
protected int doPrepare(AbstractTransactionContext context)
- Specified by:
doPrepare
in class AbstractResourceManager
doCommit
protected void doCommit(AbstractTransactionContext context)
throws ResourceManagerException
- Specified by:
doCommit
in class AbstractResourceManager
- Throws:
ResourceManagerException
doStore
protected Serializable doStore(QueueInfo queue,
Serializable object)
throws ObjectStoreException
- Throws:
ObjectStoreException
doRemove
protected void doRemove(QueueInfo queue,
Serializable id)
throws ObjectStoreException
- Throws:
ObjectStoreException
doLoad
protected Serializable doLoad(QueueInfo queue,
Serializable id)
throws ObjectStoreException
- Throws:
ObjectStoreException
doRollback
protected void doRollback(AbstractTransactionContext context)
throws ResourceManagerException
- Specified by:
doRollback
in class AbstractResourceManager
- Throws:
ResourceManagerException
findAllListableObjectStores
protected void findAllListableObjectStores()
findAllQueueStores
protected void findAllQueueStores()
setMuleContext
public void setMuleContext(MuleContext context)
- Specified by:
setMuleContext
in interface MuleContextAware
getMuleContext
public MuleContext getMuleContext()
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.