org.mule.util.queue
Interface QueueInfoDelegate

All Known Subinterfaces:

TakingQueueInfoDelegate, TransactionalQueueInfoDelegate, TransientQueueInfoDelegate

All Known Implementing Classes:

DefaultQueueInfoDelegate

public interface QueueInfoDelegate

A QueueInfo delegates the actual work of processing its queue to one of these.

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

Method Detail

putNow

void putNow(Serializable o)

append a new member to the end of the queue

offer

boolean offer(Serializable o,
              int room,
              long timeout)
              throws InterruptedException,
                     ObjectStoreException

Offer to append a new member to the end of the queue

Throws:

InterruptedException

ObjectStoreException

poll

Serializable poll(long timeout)
                  throws InterruptedException

Poll the queue for its first member, and, if there is one, remove and return it

Throws:

InterruptedException

peek

Serializable peek()
                  throws InterruptedException

return, but do not remove, the first member of the queue

Throws:

InterruptedException

untake

void untake(Serializable item)
            throws InterruptedException,
                   ObjectStoreException

Restore a previously removed member to the front of the queue

Throws:

InterruptedException

ObjectStoreException

getSize

int getSize()

Return the size of the queue

addAll

boolean addAll(Collection<? extends Serializable> items)

Appends all of the elements in the specified collection to the queue (optional operation).

Parameters:

items - to be added to the queue

Returns:

true if this queue changed as a result of the call