public static class Pub.PubSession extends XPub.XPubSession
socket| Constructor and Description |
|---|
PubSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
acceptEvent, attachPipe, connectEvent, create, destroy, detach, flush, getSocket, hiccuped, inEvent, outEvent, pipeTerminated, processAttach, processPlug, processTerm, pullMsg, pushMsg, readActivated, reset, timerEvent, toString, writeActivatedincSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAckchooseIoThread, 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, unregisterEndpointspublic PubSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)