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 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-2017 Apache Software Foundation. All Rights Reserved.