Class Req

All Implemented Interfaces:
Pipe.IPipeEvents, IPollEvents

public class Req extends Dealer
  • Field Details

    • receivingReply

      private boolean receivingReply
    • messageBegins

      private boolean messageBegins
    • replyPipe

      private final ValueReference<Pipe> replyPipe
    • requestIdFramesEnabled

      private boolean requestIdFramesEnabled
    • requestId

      private int requestId
    • strict

      private boolean strict
  • Constructor Details

    • Req

      public Req(Ctx parent, int tid, int sid)
  • Method Details

    • xsend

      public boolean xsend(Msg msg)
      Overrides:
      xsend in class Dealer
    • xrecv

      protected Msg xrecv()
      Overrides:
      xrecv in class Dealer
    • xhasIn

      public boolean xhasIn()
      Overrides:
      xhasIn in class Dealer
    • xhasOut

      public boolean xhasOut()
      Overrides:
      xhasOut in class Dealer
    • xsetsockopt

      protected boolean xsetsockopt(int option, Object optval)
      Overrides:
      xsetsockopt in class Dealer
    • xpipeTerminated

      protected void xpipeTerminated(Pipe pipe)
      Overrides:
      xpipeTerminated in class Dealer
    • recvReplyPipe

      private Msg recvReplyPipe()