Package zmq.socket.reqrep
Class Req.ReqSession
java.lang.Object
zmq.ZObject
zmq.Own
zmq.io.SessionBase
zmq.socket.reqrep.Req.ReqSession
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Enclosing class:
- Req
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsFields inherited from class zmq.io.SessionBase
socket
-
Constructor Summary
ConstructorsConstructorDescriptionReqSession
(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr) -
Method Summary
Methods inherited from class zmq.io.SessionBase
attachPipe, destroy, engineError, flush, getSocket, hiccuped, incSeqnum, pipeTerminated, processAttach, processPlug, processTerm, pullMsg, readActivated, readZapMsg, timerEvent, toString, writeActivated, writeZapMsg, zapConnect, zapEnabled
Methods inherited from class zmq.Own
isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processBind, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReaped, processStop, 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, inEvent, outEvent
-
Field Details
-
state
-
-
Constructor Details
-
ReqSession
public ReqSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
-
-
Method Details
-
pushMsg
- Overrides:
pushMsg
in classSessionBase
-
reset
public void reset()- Overrides:
reset
in classSessionBase
-