org.mule.util.queue
Class QueueTransactionContext

java.lang.Object
  org.mule.util.xa.AbstractTransactionContext
      org.mule.util.queue.QueueTransactionContext

public class QueueTransactionContext
extends AbstractTransactionContext

Field Summary

Fields inherited from class org.mule.util.xa.AbstractTransactionContext

finished, id, readOnly, status, suspended, timeout

Constructor Summary

QueueTransactionContext(TransactionalQueueManager transactionalQueueManager)

Method Summary

void	doCommit()
void	doRollback()
protected void	initializeAdded()
protected List<Serializable>	lookupQueue(QueueInfo queue)
boolean	offer(QueueInfo queue, Serializable item, long offerTimeout)
Serializable	peek(QueueInfo queue)
Serializable	poll(QueueInfo queue, long pollTimeout)
int	size(QueueInfo queue)
void	untake(QueueInfo queue, Serializable item)

Methods inherited from class org.mule.util.xa.AbstractTransactionContext

finalCleanUp, notifyFinish, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

QueueTransactionContext

public QueueTransactionContext(TransactionalQueueManager transactionalQueueManager)

Method Detail

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)