org.mule.util.queue.objectstore

Class QueueTransactionContext

java.lang.Object

org.mule.util.queue.objectstore.xa.AbstractTransactionContext

org.mule.util.queue.objectstore.QueueTransactionContext

Deprecated.

this class will be removed in Mule 4.0 in favor of the new queue implementation

@Deprecated
public class QueueTransactionContext
extends AbstractTransactionContext

Field Summary

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

finished, id, readOnly, status, suspended, timeout

Constructor Summary

Constructors

Constructor and Description
QueueTransactionContext(TransactionalQueueManager transactionalQueueManager) Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
void	clear(QueueInfo queue) Deprecated.
void	doCommit() Deprecated.
void	doRollback() Deprecated.
protected void	initializeAdded() Deprecated.
protected void	initializeRemoved() Deprecated.
protected List<Serializable>	lookupAddedQueue(QueueInfo queue) Deprecated.
protected List<Serializable>	lookupRemovedQueue(QueueInfo queue) Deprecated.
boolean	offer(QueueInfo queue, Serializable item, long offerTimeout) Deprecated.
Serializable	peek(QueueInfo queue) Deprecated.
Serializable	poll(QueueInfo queue, long pollTimeout) Deprecated.
int	size(QueueInfo queue) Deprecated.
void	untake(QueueInfo queue, Serializable item) Deprecated.

Methods inherited from class org.mule.util.queue.objectstore.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)

Deprecated.

Method Detail

offer

public boolean offer(QueueInfo queue,
            Serializable item,
            long offerTimeout)
              throws InterruptedException,
                     ObjectStoreException

Deprecated.

Throws:

InterruptedException

ObjectStoreException

untake

public void untake(QueueInfo queue,
          Serializable item)
            throws InterruptedException,
                   ObjectStoreException

Deprecated.

Throws:

InterruptedException

ObjectStoreException

clear

public void clear(QueueInfo queue)
           throws InterruptedException

Deprecated.

Throws:

InterruptedException

poll

public Serializable poll(QueueInfo queue,
                long pollTimeout)
                  throws InterruptedException,
                         ObjectStoreException

Deprecated.

Throws:

InterruptedException

ObjectStoreException

peek

public Serializable peek(QueueInfo queue)
                  throws InterruptedException,
                         ObjectStoreException

Deprecated.

Throws:

InterruptedException

ObjectStoreException

size

public int size(QueueInfo queue)

Deprecated.

doCommit

public void doCommit()
              throws ResourceManagerException

Deprecated.

Specified by:

doCommit in class AbstractTransactionContext

Throws:

ResourceManagerException

doRollback

public void doRollback()
                throws ResourceManagerException

Deprecated.

Specified by:

doRollback in class AbstractTransactionContext

Throws:

ResourceManagerException

initializeAdded

protected void initializeAdded()

Deprecated.

initializeRemoved

protected void initializeRemoved()

Deprecated.

lookupAddedQueue

protected List<Serializable> lookupAddedQueue(QueueInfo queue)

Deprecated.

lookupRemovedQueue

protected List<Serializable> lookupRemovedQueue(QueueInfo queue)

Deprecated.