Package zmq.io

Class SessionBase

    • Field Detail

      • active

        private final boolean active
      • pipe

        private Pipe pipe
      • zapPipe

        private Pipe zapPipe
      • terminatingPipes

        private final java.util.Set<Pipe> terminatingPipes
      • incompleteIn

        private boolean incompleteIn
      • pending

        private boolean pending
      • ioThread

        private final IOThread ioThread
      • hasLingerTimer

        private boolean hasLingerTimer
      • ioObject

        private final IOObject ioObject
    • Method Detail

      • destroy

        public void destroy()
        Specified by:
        destroy in class Own
      • attachPipe

        public void attachPipe​(Pipe pipe)
      • pullMsg

        protected Msg pullMsg()
      • pushMsg

        protected boolean pushMsg​(Msg msg)
      • readZapMsg

        public Msg readZapMsg()
      • writeZapMsg

        public boolean writeZapMsg​(Msg msg)
      • reset

        protected void reset()
      • flush

        public void flush()
      • cleanPipes

        private void cleanPipes()
      • zapConnect

        public int zapConnect()
      • zapEnabled

        protected boolean zapEnabled()
      • processTerm

        protected void processTerm​(int linger)
        Overrides:
        processTerm in class Own
      • timerEvent

        public void timerEvent​(int id)
        Description copied from interface: IPollEvents
        Called when timer expires.
        Specified by:
        timerEvent in interface IPollEvents
        Parameters:
        id - the ID of the expired timer.
      • reconnect

        private void reconnect()
      • startConnecting

        private void startConnecting​(boolean wait)
      • getEndpoint

        public java.lang.String getEndpoint()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • incSeqnum

        public final void incSeqnum()
        Overrides:
        incSeqnum in class Own