Package zmq.socket.pubsub

Class Dist

  • public class Dist
extends java.lang.Object

    • Field Detail

      • pipes

        private final java.util.List<Pipe> pipes

      • matching

        private int matching

      • active

        private int active

      • eligible

        private int eligible

      • more

        private boolean more

    • Constructor Detail

      • Dist

        public Dist()

    • Method Detail

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