public class AsyncMessageEngine extends MessageEngine
Modifier and Type | Class and Description |
---|---|
static class |
AsyncMessageEngine.Type |
Modifier and Type | Field and Description |
---|---|
protected double |
average |
protected java.util.HashMap<Message,java.lang.Integer> |
delays |
protected java.util.Random |
r |
protected AsyncMessageEngine.Type |
type |
debug, topology
Constructor and Description |
---|
AsyncMessageEngine(double averageDuration,
AsyncMessageEngine.Type type) |
Modifier and Type | Method and Description |
---|---|
protected void |
deliverMessage(Message m) |
protected int |
drawDelay(Message m) |
void |
onClock()
Called periodically by the central scheduler.
|
collectMessages, processMessages, setDebug, setSpeed, setTopology
protected java.util.HashMap<Message,java.lang.Integer> delays
protected double average
protected java.util.Random r
protected AsyncMessageEngine.Type type
public AsyncMessageEngine(double averageDuration, AsyncMessageEngine.Type type)
protected int drawDelay(Message m)
public void onClock()
ClockListener
onClock
in interface ClockListener
onClock
in class MessageEngine
protected void deliverMessage(Message m)
deliverMessage
in class MessageEngine