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()