Class ReplyTracker<S extends Sink>

  • All Implemented Interfaces:
    Sink, Source

    public class ReplyTracker<S extends Sink>
    extends Object
    implements Source, Sink
    Track who the reply goes to
    Author:
    zzz
    • Constructor Detail

    • Method Detail

      • setSink

        public void setSink​(Sink sink)
        Specified by:
        setSink in interface Source
      • start

        public void start()
        Specified by:
        start in interface Source
      • send

        public void send​(Destination to,
                         byte[] data)
        May throw RuntimeException from underlying sink
        Specified by:
        send in interface Sink
        Parameters:
        to - some implementations may ignore
        Throws:
        RuntimeException