public class Outbox
extends java.lang.Object
implements java.lang.Runnable, java.io.Serializable
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BROADCAST |
static java.lang.String |
IGNORE |
static org.slf4j.Logger |
log |
java.util.HashMap<java.lang.String,java.util.ArrayList<MRLListener>> |
notifyList |
static java.lang.String |
PROCESSANDBROADCAST |
static java.lang.String |
RELAY |
Constructor and Description |
---|
Outbox(NameProvider myService) |
Modifier and Type | Method and Description |
---|---|
void |
add(Message msg) |
CommunicationInterface |
getCommunicationManager() |
int |
getMaxQueueSize() |
java.util.LinkedList<Message> |
getMsgBox() |
boolean |
isBlocking() |
boolean |
isRunning() |
void |
run() |
void |
setBlocking(boolean blocking) |
void |
setCommunicationManager(CommunicationInterface c) |
int |
size() |
void |
start() |
void |
stop() |
public static final org.slf4j.Logger log
public static final java.lang.String RELAY
public static final java.lang.String IGNORE
public static final java.lang.String BROADCAST
public static final java.lang.String PROCESSANDBROADCAST
public java.util.HashMap<java.lang.String,java.util.ArrayList<MRLListener>> notifyList
public Outbox(NameProvider myService)
public void add(Message msg)
public CommunicationInterface getCommunicationManager()
public void run()
run
in interface java.lang.Runnable
public void setCommunicationManager(CommunicationInterface c)
public int size()
public void start()
public void stop()
public java.util.LinkedList<Message> getMsgBox()
public int getMaxQueueSize()
public boolean isBlocking()
public void setBlocking(boolean blocking)
public boolean isRunning()