org.mule.config
Class QueueProfile

java.lang.Object
  org.mule.config.QueueProfile

public class QueueProfile
extends Object

QueueProfile determines how an internal queue for a service will behave

Constructor Summary

QueueProfile(int maxOutstandingMessages, QueueStore<Serializable> objectStore)

QueueProfile(QueueProfile queueProfile)

QueueProfile(QueueStore<Serializable> objectStore)

Method Summary

void	addQueueStore(QueueStore<Serializable> objectStore)
QueueConfiguration	configureQueue(MuleContext context, String component, QueueManager queueManager)
int	getMaxOutstandingMessages() This specifies the number of messages that can be queued before it starts blocking.
ListableObjectStore<Serializable>	getObjectStore()
static QueueProfile	newInstancePersistingToDefaultMemoryQueueStore(MuleContext muleContext)
void	setMaxOutstandingMessages(int maxOutstandingMessages) This specifies the number of messages that can be queued before it starts blocking.
void	setQueueStore(QueueStore<Serializable> objectStore)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

QueueProfile

public QueueProfile(QueueStore<Serializable> objectStore)

QueueProfile

public QueueProfile(QueueProfile queueProfile)

QueueProfile

public QueueProfile(int maxOutstandingMessages,
                    QueueStore<Serializable> objectStore)

Method Detail

newInstancePersistingToDefaultMemoryQueueStore

public static QueueProfile newInstancePersistingToDefaultMemoryQueueStore(MuleContext muleContext)

getMaxOutstandingMessages

public int getMaxOutstandingMessages()

This specifies the number of messages that can be queued before it starts blocking.

Returns:

the max number of messages that will be queued

setMaxOutstandingMessages

public void setMaxOutstandingMessages(int maxOutstandingMessages)

This specifies the number of messages that can be queued before it starts blocking.

Parameters:

maxOutstandingMessages - the max number of messages that will be queued

configureQueue

public QueueConfiguration configureQueue(MuleContext context,
                                         String component,
                                         QueueManager queueManager)
                                  throws InitialisationException

Throws:

InitialisationException

getObjectStore

public ListableObjectStore<Serializable> getObjectStore()

setQueueStore

public void setQueueStore(QueueStore<Serializable> objectStore)

addQueueStore

public void addQueueStore(QueueStore<Serializable> objectStore)

toString

public String toString()

Overrides:

toString in class Object