org.mule.util.queue
Class QueueInfo

java.lang.Object
  org.mule.util.queue.QueueInfo

public class QueueInfo
extends Object

Stores information about a Queue

Nested Class Summary

static interface

QueueInfo.QueueInfoDelegateFactory A factory for creating object store-specific queue info delegates

Constructor Summary

QueueInfo(QueueInfo other)

QueueInfo(String name, MuleContext muleContext, QueueConfiguration config)

Method Summary

boolean	canTakeFromStore()
boolean	equals(Object obj)
int	getCapacity()
String	getName()
int	getSize()
ListableObjectStore<Serializable>	getStore()
int	hashCode()
boolean	isQueueTransactional()
boolean	isQueueTransient()
boolean	offer(Serializable o, int room, long timeout)
Serializable	peek()
Serializable	poll(long timeout)
void	putNow(Serializable o)
static void	registerDelegateFactory(Class<? extends ObjectStore> storeType, QueueInfo.QueueInfoDelegateFactory factory)
void	setConfig(QueueConfiguration config)
Serializable	takeNextItemFromStore(long timeout)
void	untake(Serializable item)
void	writeToObjectStore(Serializable data)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueInfo

public QueueInfo(String name,
                 MuleContext muleContext,
                 QueueConfiguration config)

QueueInfo

public QueueInfo(QueueInfo other)

Method Detail

setConfig

public void setConfig(QueueConfiguration config)

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getName

public String getName()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

putNow

public void putNow(Serializable o)

offer

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

Throws:

InterruptedException

ObjectStoreException

poll

public Serializable poll(long timeout)
                  throws InterruptedException

Throws:

InterruptedException

peek

public Serializable peek()
                  throws InterruptedException

Throws:

InterruptedException

untake

public void untake(Serializable item)
            throws InterruptedException,
                   ObjectStoreException

Throws:

InterruptedException

ObjectStoreException

getSize

public int getSize()

getStore

public ListableObjectStore<Serializable> getStore()

registerDelegateFactory

public static void registerDelegateFactory(Class<? extends ObjectStore> storeType,
                                           QueueInfo.QueueInfoDelegateFactory factory)

getCapacity

public int getCapacity()

canTakeFromStore

public boolean canTakeFromStore()

takeNextItemFromStore

public Serializable takeNextItemFromStore(long timeout)
                                   throws InterruptedException

Throws:

InterruptedException

writeToObjectStore

public void writeToObjectStore(Serializable data)
                        throws InterruptedException,
                               ObjectStoreException

Throws:

InterruptedException

ObjectStoreException

isQueueTransient

public boolean isQueueTransient()

isQueueTransactional

public boolean isQueueTransactional()