org.mule.util.queue

Class TransactionalQueueManager.QueueTransactionContext

java.lang.Object

org.mule.util.xa.AbstractTransactionContext

org.mule.util.queue.TransactionalQueueManager.QueueTransactionContext

Enclosing class:

TransactionalQueueManager

protected class TransactionalQueueManager.QueueTransactionContext
extends AbstractTransactionContext

Field Summary

Fields

Modifier and Type	Field and Description
protected Map	added
protected Map	removed

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

finished, id, readOnly, status, suspended, timeout

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransactionalQueueManager.QueueTransactionContext()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	offer(QueueInfo queue, Object item, long timeout)
Object	peek(QueueInfo queue)
Object	poll(QueueInfo queue, long timeout)
int	size(QueueInfo queue)

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

Field Detail

added

protected Map added

removed

protected Map removed

Constructor Detail

TransactionalQueueManager.QueueTransactionContext

protected TransactionalQueueManager.QueueTransactionContext()

Method Detail

offer

public boolean offer(QueueInfo queue,
            Object item,
            long timeout)
              throws InterruptedException

Throws:

InterruptedException

poll

public Object poll(QueueInfo queue,
          long timeout)
            throws IOException,
                   InterruptedException

Throws:

IOException

InterruptedException

peek

public Object peek(QueueInfo queue)
            throws IOException,
                   InterruptedException

Throws:

IOException

InterruptedException

size

public int size(QueueInfo queue)