public class Inbox
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
Modifier and Type | Method and Description |
---|---|
void |
add(Message msg) |
void |
clear() |
boolean |
duplicateMsg(java.util.ArrayList<RoutingEntry> history) |
Message |
getMsg()
Blocks and waits on a message put on the queue of the InBox.
|
boolean |
isBufferOverrun() |
void |
setBlocking(boolean toBlock) |
int |
size() |
public void add(Message msg)
public void clear()
public boolean duplicateMsg(java.util.ArrayList<RoutingEntry> history)
public Message getMsg() throws java.lang.InterruptedException
java.lang.InterruptedException
- eMessage
public boolean isBufferOverrun()
public void setBlocking(boolean toBlock)
public int size()