Constructor | Description |
---|---|
MultiSink(Map<Destination,S> cache) |
Modifier and Type | Method | Description |
---|---|---|
void |
send(Destination from,
byte[] data) |
May throw RuntimeException from underlying sinks
|
void |
setSink(Sink sink) |
Don't use this - put sinks in the cache
|
void |
start() |
public MultiSink(Map<Destination,S> cache)
public void setSink(Sink sink)
public void send(Destination from, byte[] data)
send
in interface Sink
from
- some implementations may ignoreRuntimeException