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	clear(QueueInfo queue)
void	doCommit()
void	doRollback()
protected void	initializeAdded()
protected void	initializeRemoved()
protected List<Serializable>	lookupAddedQueue(QueueInfo queue)
protected List<Serializable>	lookupRemovedQueue(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

clear

public void clear(QueueInfo queue)
           throws InterruptedException

Throws:

InterruptedException

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()

initializeRemoved

protected void initializeRemoved()

lookupAddedQueue

protected List<Serializable> lookupAddedQueue(QueueInfo queue)

lookupRemovedQueue

protected List<Serializable> lookupRemovedQueue(QueueInfo queue)