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

public static class Req.ReqSession
extends SessionBase

Field Summary

Fields inherited from class zmq.io.SessionBase

socket

Fields inherited from class zmq.Own

errno, options

Constructor Summary

Constructors

Constructor and Description
Req.ReqSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	pushMsg(Msg msg)
void	reset()

Methods inherited from class zmq.io.SessionBase

acceptEvent, attachPipe, connectEvent, destroy, engineError, flush, getSocket, hiccuped, incSeqnum, inEvent, outEvent, 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

Constructor Detail

Req.ReqSession

public Req.ReqSession(IOThread ioThread,
              boolean connect,
              SocketBase socket,
              Options options,
              Address addr)

Method Detail

pushMsg

public boolean pushMsg(Msg msg)

Overrides:

pushMsg in class SessionBase

reset

public void reset()

Overrides:

reset in class SessionBase