public class UnboundedMessageQueue extends Object implements MessageQueue
| Constructor and Description |
|---|
UnboundedMessageQueue() |
| Modifier and Type | Method and Description |
|---|---|
void |
add(MessageContext synCtx) |
MessageContext |
get() |
boolean |
isEmpty() |
boolean |
isPersistent() |
void |
load() |
boolean |
persist() |
public void add(MessageContext synCtx)
add in interface MessageQueuepublic MessageContext get()
get in interface MessageQueuepublic boolean isEmpty()
isEmpty in interface MessageQueuepublic boolean isPersistent()
isPersistent in interface MessageQueuepublic boolean persist()
persist in interface MessageQueuepublic void load()
load in interface MessageQueueCopyright © 2005-2017 Apache Software Foundation. All Rights Reserved.