protected class TransactionalQueueManager.QueueTransactionContext extends AbstractTransactionContext
Modifier and Type | Field and Description |
---|---|
protected Map |
added |
protected Map |
removed |
Modifier | Constructor and Description |
---|---|
protected |
TransactionalQueueManager.QueueTransactionContext() |
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) |
finalCleanUp, notifyFinish, toString
protected TransactionalQueueManager.QueueTransactionContext()
public boolean offer(QueueInfo queue, Object item, long timeout) throws InterruptedException
InterruptedException
public Object poll(QueueInfo queue, long timeout) throws IOException, InterruptedException
IOException
InterruptedException
public Object peek(QueueInfo queue) throws IOException, InterruptedException
IOException
InterruptedException
public int size(QueueInfo queue)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.