| Constructor and Description |
|---|
ReplyTracker(S reply,
Map<Destination,S> cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
send(Destination to,
byte[] data)
May throw RuntimeException from underlying sink
|
void |
setSink(Sink sink) |
void |
start() |
public ReplyTracker(S reply, Map<Destination,S> cache)
public void send(Destination to, byte[] data)
send in interface Sinkto - some implementations may ignoreRuntimeException