Class Dist

java.lang.Object
zmq.socket.pubsub.Dist
public class Dist extends Object

  • Field Details

    • pipes

      private final List<Pipe> pipes

    • matching

      private int matching

    • active

      private int active

    • eligible

      private int eligible

    • more

      private boolean more

  • Constructor Details

    • Dist

      public Dist()

  • Method Details

    • attach

      public void attach(Pipe pipe)

    • match

      public void match(Pipe pipe)

    • unmatch

      public void unmatch()

    • terminated

      public void terminated(Pipe pipe)

    • activated

      public void activated(Pipe pipe)

    • sendToAll

      public boolean sendToAll(Msg msg)

    • sendToMatching

      public boolean sendToMatching(Msg msg)

    • distribute

      private void distribute(Msg msg)

    • hasOut

      public boolean hasOut()

    • write

      private boolean write(Pipe pipe, Msg msg)

    • checkHwm

      public boolean checkHwm()

    • active

      int active()

    • eligible

      int eligible()

    • matching

      int matching()