Class UnboundedMessageQueue
- java.lang.Object
-
- org.apache.synapse.mediators.eip.sample.UnboundedMessageQueue
-
- All Implemented Interfaces:
MessageQueue
public class UnboundedMessageQueue extends Object implements MessageQueue
-
-
Constructor Summary
Constructors Constructor Description UnboundedMessageQueue()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(MessageContext synCtx)
MessageContext
get()
boolean
isEmpty()
boolean
isPersistent()
void
load()
boolean
persist()
-
-
-
Method Detail
-
add
public void add(MessageContext synCtx)
- Specified by:
add
in interfaceMessageQueue
-
get
public MessageContext get()
- Specified by:
get
in interfaceMessageQueue
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmpty
in interfaceMessageQueue
-
isPersistent
public boolean isPersistent()
- Specified by:
isPersistent
in interfaceMessageQueue
-
persist
public boolean persist()
- Specified by:
persist
in interfaceMessageQueue
-
load
public void load()
- Specified by:
load
in interfaceMessageQueue
-
-