public class TransactionalQueueManager extends AbstractXAResourceManager implements QueueManager
Modifier and Type | Class and Description |
---|---|
protected class |
TransactionalQueueManager.QueueTransactionContext |
activeContexts, suspendedContexts
DEFAULT_COMMIT_TIMEOUT_FACTOR, DEFAULT_TIMEOUT_MSECS, defaultTimeout, dirty, globalTransactions, 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
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
TransactionalQueueManager() |
includeBranchInXid
assureReady, assureStarted, beginTransaction, commitTransaction, getDefaultTransactionTimeout, prepareTransaction, rollbackTransaction, setDefaultTransactionTimeout, setDirty, setTransactionRollbackOnly, start, startTransaction, stop, stop, stop, waitForAllTxToStop
public QueueSession getQueueSession()
getQueueSession
in interface QueueManager
public void setDefaultQueueConfiguration(QueueConfiguration config)
setDefaultQueueConfiguration
in interface QueueManager
public void setQueueConfiguration(String queueName, QueueConfiguration config)
setQueueConfiguration
in interface QueueManager
protected org.apache.commons.logging.Log getLogger()
getLogger
in class AbstractResourceManager
protected void doStart() throws ResourceManagerSystemException
doStart
in class AbstractResourceManager
ResourceManagerSystemException
protected boolean shutdown(int mode, long timeoutMSecs)
shutdown
in class AbstractResourceManager
protected void recover() throws ResourceManagerSystemException
recover
in class AbstractResourceManager
ResourceManagerSystemException
protected AbstractTransactionContext createTransactionContext(Object session)
createTransactionContext
in class AbstractResourceManager
protected void doBegin(AbstractTransactionContext context)
doBegin
in class AbstractResourceManager
protected int doPrepare(AbstractTransactionContext context)
doPrepare
in class AbstractResourceManager
protected void doCommit(AbstractTransactionContext context) throws ResourceManagerException
doCommit
in class AbstractResourceManager
ResourceManagerException
protected Object doStore(QueueInfo queue, Object object) throws IOException
IOException
protected void doRemove(QueueInfo queue, Object id) throws IOException
IOException
protected Object doLoad(QueueInfo queue, Object id) throws IOException
IOException
protected void doRollback(AbstractTransactionContext context) throws ResourceManagerException
doRollback
in class AbstractResourceManager
ResourceManagerException
public QueuePersistenceStrategy getPersistenceStrategy()
getPersistenceStrategy
in interface QueueManager
public void setPersistenceStrategy(QueuePersistenceStrategy persistenceStrategy)
setPersistenceStrategy
in interface QueueManager
persistenceStrategy
- The persistenceStrategy to set.public QueuePersistenceStrategy getMemoryPersistenceStrategy()
getMemoryPersistenceStrategy
in interface QueueManager
public void setMemoryPersistenceStrategy(QueuePersistenceStrategy memoryPersistenceStrategy)
setMemoryPersistenceStrategy
in interface QueueManager
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.