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

Constructors

Constructor and Description
QueueProfile(int maxOutstandingMessages, QueueStore<Serializable> objectStore)
QueueProfile(QueueProfile queueProfile)
QueueProfile(QueueStore<Serializable> objectStore)

Method Summary

Methods

Modifier and Type	Method and Description
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)
static QueueProfile	newInstanceWithPersistentQueueStore(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)
QueueConfiguration	toQueueConfiguration(MuleContext context)
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)

newInstanceWithPersistentQueueStore

public static QueueProfile newInstanceWithPersistentQueueStore(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

toQueueConfiguration

public QueueConfiguration toQueueConfiguration(MuleContext context)

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