ostore.dispatch
Class Classifier.SlowLink
java.lang.Object
|
+--ostore.dispatch.Classifier.SlowLink
- Enclosing class:
- Classifier
- public class Classifier.SlowLink
- extends Object
Records information used to delay events sent from one named stage
to another.
Field Summary |
long |
delay
The number of milliseconds to delay messages on this link. |
String |
receiver
The name of the receiving stage |
String |
sender
The name of the sending stage |
SinkIF |
sink
The SinkIF for the receiver
TODO: allow more than one sink? |
Thread |
thread
The Thread object for the sender
TODO: allow more than one thread per stage? |
Classifier.TimerCB |
timer
A timer interface for sink . |
Method Summary |
void |
enqueue(QueueElementIF event)
Place the event on the receiver's sink in delay
milliseconds. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
sender
public String sender
- The name of the sending stage
receiver
public String receiver
- The name of the receiving stage
delay
public long delay
- The number of milliseconds to delay messages on this link.
thread
public Thread thread
- The
Thread
object for the sender
TODO: allow more than one thread per stage?
sink
public SinkIF sink
- The
SinkIF
for the receiver
TODO: allow more than one sink?
timer
public Classifier.TimerCB timer
- A timer interface for
sink
.
Classifier.SlowLink
public Classifier.SlowLink(String sender,
String receiver,
long delay)
throws NoSuchStageException
- Creates a new
SlowLink
.
enqueue
public void enqueue(QueueElementIF event)
- Place the event on the receiver's sink in
delay
milliseconds.