|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.mule.util.queue.DefaultQueueInfoDelegate
public class DefaultQueueInfoDelegate
The default QueueInfoDelegate. This uses a LinkedList to store the members of the queue.
Field Summary | |
---|---|
protected int |
capacity
|
protected LinkedList<Serializable> |
list
|
Constructor Summary | |
---|---|
DefaultQueueInfoDelegate(int capacity)
|
Method Summary | |
---|---|
boolean |
addAll(Collection<? extends Serializable> items)
Appends all of the elements in the specified collection to the queue (optional operation). |
int |
getSize()
Return the size of the queue |
boolean |
offer(Serializable o,
int room,
long timeout)
Offer to append a new member to the end of the queue |
Serializable |
peek()
return, but do not remove, the first member of the queue |
Serializable |
poll(long timeout)
Poll the queue for its first member, and, if there is one, remove and return it |
void |
putNow(Serializable o)
append a new member to the end of the queue |
void |
untake(Serializable item)
Restore a previously removed member to the front of the queue |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final int capacity
protected final LinkedList<Serializable> list
Constructor Detail |
---|
public DefaultQueueInfoDelegate(int capacity)
Method Detail |
---|
public void putNow(Serializable o)
QueueInfoDelegate
putNow
in interface QueueInfoDelegate
public boolean offer(Serializable o, int room, long timeout) throws InterruptedException
QueueInfoDelegate
offer
in interface QueueInfoDelegate
InterruptedException
public Serializable poll(long timeout) throws InterruptedException
QueueInfoDelegate
poll
in interface QueueInfoDelegate
InterruptedException
public Serializable peek() throws InterruptedException
QueueInfoDelegate
peek
in interface QueueInfoDelegate
InterruptedException
public void untake(Serializable item) throws InterruptedException
QueueInfoDelegate
untake
in interface QueueInfoDelegate
InterruptedException
public int getSize()
QueueInfoDelegate
getSize
in interface QueueInfoDelegate
public boolean addAll(Collection<? extends Serializable> items)
QueueInfoDelegate
addAll
in interface QueueInfoDelegate
items
- to be added to the queue
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |