org.mule.config
Class QueueProfile

java.lang.Object
  extended byorg.mule.config.QueueProfile

public class QueueProfile
extends java.lang.Object

QueueProfile determines how an internal queue for a component will behave

Version:
$Revision: 1.3 $
Author:
Ross Mason

Constructor Summary
QueueProfile()
           
QueueProfile(int maxOutstandingMessages, PersistenceStrategy persistenceStrategy)
           
QueueProfile(QueueProfile queueProfile)
           
 
Method Summary
 BoundedPersistentQueue createQueue(java.lang.String component)
           
 long getBlockWait()
           
 int getMaxOutstandingMessages()
          This specifies the number of messages that can be queued for this component before it starts blocking.
 PersistenceStrategy getPersistenceStrategy()
           
 void setBlockWait(long blockWait)
           
 void setMaxOutstandingMessages(int maxOutstandingMessages)
          This specifies the number of messages that can be queued for this component before it starts blocking.
 void setPersistenceStrategy(PersistenceStrategy persistenceStrategy)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

QueueProfile

public QueueProfile()

QueueProfile

public QueueProfile(int maxOutstandingMessages,
                    PersistenceStrategy persistenceStrategy)

QueueProfile

public QueueProfile(QueueProfile queueProfile)
Method Detail

getMaxOutstandingMessages

public int getMaxOutstandingMessages()
This specifies the number of messages that can be queued for this component 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 for this component before it starts blocking.

Parameters:
maxOutstandingMessages - the max number of messages that will be queued

getPersistenceStrategy

public PersistenceStrategy getPersistenceStrategy()

setPersistenceStrategy

public void setPersistenceStrategy(PersistenceStrategy persistenceStrategy)

createQueue

public BoundedPersistentQueue createQueue(java.lang.String component)
                                   throws InitialisationException
Throws:
InitialisationException

getBlockWait

public long getBlockWait()

setBlockWait

public void setBlockWait(long blockWait)


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.