org.mule.util.queue
Class QueueTransactionContext
java.lang.Object
org.mule.util.xa.AbstractTransactionContext
org.mule.util.queue.QueueTransactionContext
public class QueueTransactionContext
- extends AbstractTransactionContext
QueueTransactionContext
public QueueTransactionContext(TransactionalQueueManager transactionalQueueManager)
offer
public boolean offer(QueueInfo queue,
Serializable item,
long offerTimeout)
throws InterruptedException,
ObjectStoreException
- Throws:
InterruptedException
ObjectStoreException
untake
public void untake(QueueInfo queue,
Serializable item)
throws InterruptedException,
ObjectStoreException
- Throws:
InterruptedException
ObjectStoreException
poll
public Serializable poll(QueueInfo queue,
long pollTimeout)
throws InterruptedException,
ObjectStoreException
- Throws:
InterruptedException
ObjectStoreException
peek
public Serializable peek(QueueInfo queue)
throws InterruptedException,
ObjectStoreException
- Throws:
InterruptedException
ObjectStoreException
size
public int size(QueueInfo queue)
doCommit
public void doCommit()
throws ResourceManagerException
- Specified by:
doCommit
in class AbstractTransactionContext
- Throws:
ResourceManagerException
doRollback
public void doRollback()
throws ResourceManagerException
- Specified by:
doRollback
in class AbstractTransactionContext
- Throws:
ResourceManagerException
initializeAdded
protected void initializeAdded()
lookupQueue
protected List<Serializable> lookupQueue(QueueInfo queue)
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.