zmq

Class Req.ReqSession

java.lang.Object

zmq.ZObject

zmq.Own

zmq.SessionBase

zmq.Dealer.DealerSession

zmq.Req.ReqSession

All Implemented Interfaces:

IMsgSink, IMsgSource, IPollEvents, Pipe.IPipeEvents

Enclosing class:

Req

public static class Req.ReqSession
extends Dealer.DealerSession

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	Req.ReqSession.State

Field Summary

Fields

Modifier and Type	Field and Description
private Req.ReqSession.State	state

Fields inherited from class zmq.SessionBase

socket

Fields inherited from class zmq.Own

options

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class zmq.SessionBase

acceptEvent, attachPipe, connectEvent, create, destroy, detach, flush, getSocket, hiccuped, inEvent, outEvent, pipeTerminated, processAttach, processPlug, processTerm, pullMsg, readActivated, timerEvent, toString, writeActivated

Methods inherited from class zmq.Own

incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAck

Methods inherited from class zmq.ZObject

chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processBind, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints

Methods inherited from class java.lang.Object

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

Field Detail

state

private Req.ReqSession.State state

Constructor Detail

ReqSession

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

Method Detail

pushMsg

public int pushMsg(Msg msg)

Specified by:

pushMsg in interface IMsgSink

Overrides:

pushMsg in class SessionBase

reset

public void reset()

Overrides:

reset in class SessionBase