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 final ValueReference<Pipe>	replyPipe
private int	requestId
private boolean	requestIdFramesEnabled
private boolean	strict

Fields inherited from class SocketBase

connectRid

Fields inherited from class Own

errno, options

Constructor Summary

Constructors

Constructor	Description
Req(Ctx parent, int tid, int sid)

Method Summary

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, Object optval)

Methods inherited from class Dealer

getCredential, recvpipe, sendpipe, xattachPipe, xreadActivated, xwriteActivated

Methods inherited from class SocketBase

bind, cancel, close, connect, connectPeer, destroy, disconnectPeer, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshakeFailedAuth, eventHandshakeFailedNoDetail, eventHandshakeFailedProtocol, eventHandshaken, eventHandshakeSucceeded, eventListening, getFD, getSocketOpt, getSocketOptx, hiccuped, inEvent, join, leave, monitor, monitorEvent, pipeTerminated, poll, processBind, processDestroy, processStop, processTerm, readActivated, recv, recv, send, send, setSocketOpt, termEndpoint, toString, typeString, writeActivated, xdisconnectPeer, xhiccuped, xjoin, xleave

Methods inherited from class Own

incSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate

Methods inherited from class ZObject

chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processCancel, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReapAck, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendCancel, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReapAck, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface IPollEvents

acceptEvent, connectEvent, outEvent, timerEvent

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