Package zmq.io

Class SessionBase

All Implemented Interfaces:
Pipe.IPipeEvents, IPollEvents
Direct Known Subclasses:
Dish.DishSession, HelloMsgSession, Radio.RadioSession, Req.ReqSession

public class SessionBase extends Own implements Pipe.IPipeEvents, IPollEvents
  • Field Details

    • active

      private final boolean active
    • pipe

      private Pipe pipe
    • zapPipe

      private Pipe zapPipe
    • terminatingPipes

      private final Set<Pipe> terminatingPipes
    • incompleteIn

      private boolean incompleteIn
    • pending

      private boolean pending
    • engine

      private IEngine engine
    • socket

      protected final SocketBase socket
    • ioThread

      private final IOThread ioThread
    • LINGER_TIMER_ID

      private static final int LINGER_TIMER_ID
      See Also:
    • hasLingerTimer

      private boolean hasLingerTimer
    • addr

      private final Address addr
    • ioObject

      private final IOObject ioObject
  • Constructor Details

  • Method Details

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

      public void pipeTerminated(Pipe pipe)
      Specified by:
      pipeTerminated in interface Pipe.IPipeEvents
    • readActivated

      public void readActivated(Pipe pipe)
      Specified by:
      readActivated in interface Pipe.IPipeEvents
    • writeActivated

      public void writeActivated(Pipe pipe)
      Specified by:
      writeActivated in interface Pipe.IPipeEvents
    • hiccuped

      public void hiccuped(Pipe pipe)
      Specified by:
      hiccuped in interface Pipe.IPipeEvents
    • getSocket

      public SocketBase getSocket()
    • processPlug

      protected void processPlug()
      Overrides:
      processPlug in class ZObject
    • zapConnect

      public int zapConnect()
    • zapEnabled

      protected boolean zapEnabled()
    • processAttach

      protected void processAttach(IEngine engine)
      Overrides:
      processAttach in class ZObject
    • engineError

      public void engineError(boolean handshaked, StreamEngine.ErrorReason reason)
    • 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 String getEndpoint()
    • toString

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

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