Constructor Detail

• MultiSink

  public MultiSink(Map<Integer,S> cache)

  Parameters:

  cache - map of toPort to Sink

Method Detail

• send

  public void send(Destination from,
                   int fromPort,
                   int toPort,
                   byte[] data)

  Send to a single sink looked up by toPort May throw RuntimeException from underlying sinks

  Specified by:

  send in interface Sink

  Parameters:

  from - passed along

  fromPort - passed along

  toPort - passed along

  Throws:

  RuntimeException

• setSink

  public void setSink(Sink sink)

  Don't use this - put sinks in the cache

  Specified by:

  setSink in interface Source

  Parameters:

  sink - the sink to receive data

• start

  public void start()

  Description copied from interface: Source
  Starts the source.

  Specified by:

  start in interface Source