public abstract class ZObject extends Object
Modifier | Constructor and Description |
---|---|
protected |
ZObject(Ctx ctx,
int tid) |
protected |
ZObject(ZObject parent) |
Modifier and Type | Method and Description |
---|---|
protected IOThread |
chooseIoThread(long affinity) |
protected void |
destroySocket(SocketBase socket) |
protected zmq.Ctx.Endpoint |
findEndpoint(String addr) |
protected Ctx |
getCtx() |
protected int |
getTid() |
protected void |
processActivateRead() |
protected void |
processActivateWrite(long msgsRead) |
protected void |
processAttach(IEngine engine) |
protected void |
processBind(zmq.Pipe pipe) |
protected void |
processCommand(zmq.Command cmd) |
protected void |
processHiccup(Object hiccupPipe) |
protected void |
processOwn(zmq.Own object) |
protected void |
processPipeTerm() |
protected void |
processPipeTermAck() |
protected void |
processPlug() |
protected void |
processReap(SocketBase socket) |
protected void |
processReaped() |
protected void |
processSeqnum() |
protected void |
processStop() |
protected void |
processTerm(int linger) |
protected void |
processTermAck() |
protected void |
processTermReq(zmq.Own object) |
protected boolean |
registerEndpoint(String addr,
zmq.Ctx.Endpoint endpoint) |
protected void |
sendActivateRead(zmq.Pipe destination) |
protected void |
sendActivateWrite(zmq.Pipe destination,
long msgsRead) |
protected void |
sendAttach(zmq.SessionBase destination,
IEngine engine) |
protected void |
sendAttach(zmq.SessionBase destination,
IEngine engine,
boolean incSeqnum) |
protected void |
sendBind(zmq.Own destination,
zmq.Pipe pipe) |
protected void |
sendBind(zmq.Own destination,
zmq.Pipe pipe,
boolean incSeqnum) |
protected void |
sendDone() |
protected void |
sendHiccup(zmq.Pipe destination,
Object pipe) |
protected void |
sendOwn(zmq.Own destination,
zmq.Own object) |
protected void |
sendPipeTerm(zmq.Pipe destination) |
protected void |
sendPipeTermAck(zmq.Pipe destination) |
protected void |
sendPlug(zmq.Own destination) |
protected void |
sendPlug(zmq.Own destination,
boolean incSeqnum) |
protected void |
sendReap(SocketBase socket) |
protected void |
sendReaped() |
protected void |
sendStop() |
protected void |
sendTerm(zmq.Own destination,
int linger) |
protected void |
sendTermAck(zmq.Own destination) |
protected void |
sendTermReq(zmq.Own destination,
zmq.Own object) |
protected void |
unregisterEndpoints(SocketBase socket) |
protected ZObject(Ctx ctx, int tid)
protected ZObject(ZObject parent)
protected int getTid()
protected Ctx getCtx()
protected void processCommand(zmq.Command cmd)
protected boolean registerEndpoint(String addr, zmq.Ctx.Endpoint endpoint)
protected void unregisterEndpoints(SocketBase socket)
protected zmq.Ctx.Endpoint findEndpoint(String addr)
protected void destroySocket(SocketBase socket)
protected IOThread chooseIoThread(long affinity)
protected void sendStop()
protected void sendPlug(zmq.Own destination)
protected void sendPlug(zmq.Own destination, boolean incSeqnum)
protected void sendOwn(zmq.Own destination, zmq.Own object)
protected void sendAttach(zmq.SessionBase destination, IEngine engine)
protected void sendAttach(zmq.SessionBase destination, IEngine engine, boolean incSeqnum)
protected void sendBind(zmq.Own destination, zmq.Pipe pipe)
protected void sendBind(zmq.Own destination, zmq.Pipe pipe, boolean incSeqnum)
protected void sendActivateRead(zmq.Pipe destination)
protected void sendActivateWrite(zmq.Pipe destination, long msgsRead)
protected void sendHiccup(zmq.Pipe destination, Object pipe)
protected void sendPipeTerm(zmq.Pipe destination)
protected void sendPipeTermAck(zmq.Pipe destination)
protected void sendTermReq(zmq.Own destination, zmq.Own object)
protected void sendTerm(zmq.Own destination, int linger)
protected void sendTermAck(zmq.Own destination)
protected void sendReap(SocketBase socket)
protected void sendReaped()
protected void sendDone()
protected void processStop()
protected void processPlug()
protected void processOwn(zmq.Own object)
protected void processAttach(IEngine engine)
protected void processBind(zmq.Pipe pipe)
protected void processActivateRead()
protected void processActivateWrite(long msgsRead)
protected void processHiccup(Object hiccupPipe)
protected void processPipeTerm()
protected void processPipeTermAck()
protected void processTermReq(zmq.Own object)
protected void processTerm(int linger)
protected void processTermAck()
protected void processReap(SocketBase socket)
protected void processReaped()
protected void processSeqnum()
Copyright © 2016. All rights reserved.