public class TransactionAwareQueueStore extends Object implements Queue
QueueStoreCacheListener
will be notifiedConstructor and Description |
---|
TransactionAwareQueueStore(QueueStore queue,
TransactionContextProvider transactionContextProvider,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Discards all the elements in the queue
|
void |
dispose()
Disposes this queue by releasing it's storage and associated memory and
storage.
|
String |
getName()
Gets the name of the object
|
boolean |
offer(Serializable item,
long timeout) |
Serializable |
peek() |
Serializable |
poll(long timeout) |
void |
put(Serializable item)
Puts a new object in this queue and wait if necessary.
|
int |
size()
Returns the number of elements in this queue.
|
Serializable |
take()
Blocks and retrieves an object from this queue.
|
void |
untake(Serializable item) |
protected transient Log logger
public TransactionAwareQueueStore(QueueStore queue, TransactionContextProvider transactionContextProvider, MuleContext muleContext)
public void put(Serializable item) throws InterruptedException, ObjectStoreException
Queue
put
in interface Queue
InterruptedException
ObjectStoreException
public void clear() throws InterruptedException
Queue
clear
in interface Queue
InterruptedException
public boolean offer(Serializable item, long timeout) throws InterruptedException, ObjectStoreException
offer
in interface Queue
InterruptedException
ObjectStoreException
public Serializable take() throws InterruptedException
Queue
take
in interface Queue
InterruptedException
public void untake(Serializable item) throws InterruptedException, ObjectStoreException
untake
in interface Queue
InterruptedException
ObjectStoreException
public Serializable poll(long timeout) throws InterruptedException
poll
in interface Queue
InterruptedException
public Serializable peek() throws InterruptedException
peek
in interface Queue
InterruptedException
public void dispose() throws MuleException, InterruptedException
Queue
dispose
in interface Queue
MuleException
InterruptedException
public int size()
Queue
public String getName()
NamedObject
getName
in interface NamedObject
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.