public class UnboundedMessageQueue extends java.lang.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 MessageQueue
public MessageContext get()
get
in interface MessageQueue
public boolean isEmpty()
isEmpty
in interface MessageQueue
public boolean isPersistent()
isPersistent
in interface MessageQueue
public boolean persist()
persist
in interface MessageQueue
public void load()
load
in interface MessageQueue
Copyright © 2005-2020 Apache Software Foundation. All Rights Reserved.