public class MessageEngine extends java.lang.Object implements ClockListener
The MessageEngine
is responsible for regularly (it is a ClockListener
) transmitting available
Message
s from any sender Node
of the Topology
to their destination.
Modifier and Type | Field and Description |
---|---|
protected boolean |
debug |
protected Topology |
topology |
Constructor and Description |
---|
MessageEngine() |
Modifier and Type | Method and Description |
---|---|
protected java.util.ArrayList<Message> |
collectMessages() |
protected void |
deliverMessage(Message m) |
void |
onClock()
Called periodically by the central scheduler.
|
protected void |
processMessages(java.util.ArrayList<Message> messages) |
void |
setDebug(boolean debug) |
void |
setSpeed(int speed) |
void |
setTopology(Topology topology) |
protected Topology topology
protected boolean debug
public void setTopology(Topology topology)
public void setSpeed(int speed)
public void onClock()
ClockListener
onClock
in interface ClockListener
protected java.util.ArrayList<Message> collectMessages()
protected void processMessages(java.util.ArrayList<Message> messages)
protected void deliverMessage(Message m)
public void setDebug(boolean debug)