Package zmq

Class Own

    • Field Detail

      • options

        protected final Options options
      • terminating

        private boolean terminating
      • sendSeqnum

        private final java.util.concurrent.atomic.AtomicLong sendSeqnum
      • processedSeqnum

        private long processedSeqnum
      • owner

        private Own owner
      • owned

        private final java.util.Set<Own> owned
      • termAcks

        private int termAcks
      • errno

        public final Errno errno
    • Constructor Detail

      • Own

        protected Own​(Ctx parent,
                      int tid)
    • Method Detail

      • destroy

        protected abstract void destroy()
      • processDestroy

        protected void processDestroy()
      • setOwner

        private void setOwner​(Own owner)
      • incSeqnum

        protected void incSeqnum()
      • launchChild

        protected final void launchChild​(Own object)
      • termChild

        protected final void termChild​(Own object)
      • processOwn

        protected final void processOwn​(Own object)
        Overrides:
        processOwn in class ZObject
      • terminate

        protected final void terminate()
      • isTerminating

        protected final boolean isTerminating()
      • processTerm

        protected void processTerm​(int linger)
        Overrides:
        processTerm in class ZObject
      • registerTermAcks

        final void registerTermAcks​(int count)
      • unregisterTermAck

        final void unregisterTermAck()
      • checkTermAcks

        private void checkTermAcks()