public final class QueueProfile extends AbstractComponent
QueueProfile
determines how an internal queue for a service will behaveLOCATION_KEY, ROOT_CONTAINER_NAME_KEY
ANNOTATIONS_PROPERTY_NAME
Constructor and Description |
---|
QueueProfile(boolean persistent) |
QueueProfile(int maxOutstandingMessages,
boolean persistent) |
Modifier and Type | Method and Description |
---|---|
QueueConfiguration |
configureQueue(String component,
QueueManager queueManager) |
int |
getMaxOutstandingMessages()
This specifies the number of messages that can be queued before it starts blocking.
|
static QueueProfile |
newInstancePersistingToDefaultMemoryQueueStore() |
static QueueProfile |
newInstanceWithPersistentQueueStore() |
void |
setMaxOutstandingMessages(int maxOutstandingMessages)
This specifies the number of messages that can be queued before it starts blocking.
|
String |
toString() |
getAnnotation, getAnnotations, getLocation, getRootContainerLocation, setAnnotations
public QueueProfile(boolean persistent)
public QueueProfile(int maxOutstandingMessages, boolean persistent)
public static QueueProfile newInstancePersistingToDefaultMemoryQueueStore()
public static QueueProfile newInstanceWithPersistentQueueStore()
public int getMaxOutstandingMessages()
public void setMaxOutstandingMessages(int maxOutstandingMessages)
maxOutstandingMessages
- the max number of messages that will be queuedpublic QueueConfiguration configureQueue(String component, QueueManager queueManager) throws InitialisationException
InitialisationException
Copyright © 2018. All rights reserved.