Package zmq.socket.reqrep
Class Req
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.SocketBase
-
- zmq.socket.reqrep.Dealer
-
- zmq.socket.reqrep.Req
-
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
public class Req extends Dealer
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Req.ReqSession
-
Field Summary
Fields Modifier and Type Field Description private boolean
messageBegins
private boolean
receivingReply
private ValueReference<Pipe>
replyPipe
private int
requestId
private boolean
requestIdFramesEnabled
private boolean
strict
-
Fields inherited from class zmq.SocketBase
connectRid
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private Msg
recvReplyPipe()
boolean
xhasIn()
boolean
xhasOut()
protected void
xpipeTerminated(Pipe pipe)
protected Msg
xrecv()
boolean
xsend(Msg msg)
protected boolean
xsetsockopt(int option, java.lang.Object optval)
-
Methods inherited from class zmq.socket.reqrep.Dealer
getCredential, recvpipe, sendpipe, xattachPipe, xreadActivated, xwriteActivated
-
Methods inherited from class zmq.SocketBase
bind, close, connect, destroy, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshaken, eventListening, getFD, getSocketOpt, getSocketOptx, hiccuped, inEvent, monitor, monitorEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, termEndpoint, toString, typeString, writeActivated, xhiccuped
-
Methods inherited from class zmq.Own
incSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
-
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface zmq.poll.IPollEvents
acceptEvent, connectEvent, outEvent, timerEvent
-
-
-
-
Field Detail
-
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 Detail
-
Req
public Req(Ctx parent, int tid, int sid)
-
-
Method Detail
-
xsetsockopt
protected boolean xsetsockopt(int option, java.lang.Object optval)
- Overrides:
xsetsockopt
in classDealer
-
xpipeTerminated
protected void xpipeTerminated(Pipe pipe)
- Overrides:
xpipeTerminated
in classDealer
-
recvReplyPipe
private Msg recvReplyPipe()
-
-