Class XPub

    • Field Detail

      • subscriptions

        private final Mtrie subscriptions
      • manualSubscriptions

        private final Mtrie manualSubscriptions
      • dist

        private final Dist dist
      • verboseSubs

        private boolean verboseSubs
      • verboseUnsubs

        private boolean verboseUnsubs
      • more

        private boolean more
      • lossy

        private boolean lossy
      • manual

        private boolean manual
      • lastPipe

        private Pipe lastPipe
      • pendingPipes

        private final java.util.Deque<Pipe> pendingPipes
      • pendingData

        private final java.util.Deque<Blob> pendingData
      • pendingFlags

        private final java.util.Deque<java.lang.Integer> pendingFlags
    • Constructor Detail

      • XPub

        public XPub​(Ctx parent,
                    int tid,
                    int sid)
    • Method Detail

      • xattachPipe

        protected void xattachPipe​(Pipe pipe,
                                   boolean subscribeToAll,
                                   boolean isLocallyInitiated)
        Specified by:
        xattachPipe in class SocketBase
      • xsetsockopt

        public boolean xsetsockopt​(int option,
                                   java.lang.Object optval)
        Overrides:
        xsetsockopt in class SocketBase
      • markAsMatching

        private void markAsMatching​(Pipe pipe)
      • sendUnsubscription

        private void sendUnsubscription​(byte[] data,
                                        int size)