public class Pub extends XPub
| Modifier and Type | Class and Description |
|---|---|
static class |
Pub.PubSession |
XPub.XPubSessionerrno| Modifier and Type | Method and Description |
|---|---|
protected boolean |
xhasIn() |
protected Msg |
xrecv() |
xattachPipe, xhasOut, xpipeTerminated, xreadActivated, xsend, xsetsockopt, xwriteActivatedacceptEvent, bind, checkTag, close, connect, connectEvent, create, destroy, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventListening, getFD, getMailbox, getSocketOpt, getsockoptx, hasIn, hasOut, hiccuped, inEvent, monitor, monitorEvent, outEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, startReaping, stop, stopMonitor, termEndpoint, timerEvent, toString, typeString, writeActivated, xhiccupedincSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAckchooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints