zmq

Class ZObject

java.lang.Object

zmq.ZObject

Direct Known Subclasses:

Dealer.DealerSession, IOThread, Pair.PairSession, Push.PushSession, Reaper, Router.RouterSession, SocketBase, TcpConnecter, TcpListener, XPub.XPubSession, XSub.XSubSession

public abstract class ZObject
extends Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ZObject(Ctx ctx, int tid)
protected	ZObject(ZObject parent)

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZObject

protected ZObject(Ctx ctx,
       int tid)

ZObject

protected ZObject(ZObject parent)

Method Detail

getTid

protected int getTid()

getCtx

protected Ctx getCtx()

processCommand

protected void processCommand(zmq.Command cmd)

registerEndpoint

protected boolean registerEndpoint(String addr,
                       zmq.Ctx.Endpoint endpoint)

unregisterEndpoints

protected void unregisterEndpoints(SocketBase socket)

findEndpoint

protected zmq.Ctx.Endpoint findEndpoint(String addr)

destroySocket

protected void destroySocket(SocketBase socket)

chooseIoThread

protected IOThread chooseIoThread(long affinity)

sendStop

protected void sendStop()

sendPlug

protected void sendPlug(zmq.Own destination)

sendPlug

protected void sendPlug(zmq.Own destination,
            boolean incSeqnum)

sendOwn

protected void sendOwn(zmq.Own destination,
           zmq.Own object)

sendAttach

protected void sendAttach(zmq.SessionBase destination,
              IEngine engine)

sendAttach

protected void sendAttach(zmq.SessionBase destination,
              IEngine engine,
              boolean incSeqnum)

sendBind

protected void sendBind(zmq.Own destination,
            zmq.Pipe pipe)

sendBind

protected void sendBind(zmq.Own destination,
            zmq.Pipe pipe,
            boolean incSeqnum)

sendActivateRead

protected void sendActivateRead(zmq.Pipe destination)

sendActivateWrite

protected void sendActivateWrite(zmq.Pipe destination,
                     long msgsRead)

sendHiccup

protected void sendHiccup(zmq.Pipe destination,
              Object pipe)

sendPipeTerm

protected void sendPipeTerm(zmq.Pipe destination)

sendPipeTermAck

protected void sendPipeTermAck(zmq.Pipe destination)

sendTermReq

protected void sendTermReq(zmq.Own destination,
               zmq.Own object)

sendTerm

protected void sendTerm(zmq.Own destination,
            int linger)

sendTermAck

protected void sendTermAck(zmq.Own destination)

sendReap

protected void sendReap(SocketBase socket)

sendReaped

protected void sendReaped()

sendDone

protected void sendDone()

processStop

protected void processStop()

processPlug

protected void processPlug()

processOwn

protected void processOwn(zmq.Own object)

processAttach

protected void processAttach(IEngine engine)

processBind

protected void processBind(zmq.Pipe pipe)

processActivateRead

protected void processActivateRead()

processActivateWrite

protected void processActivateWrite(long msgsRead)

processHiccup

protected void processHiccup(Object hiccupPipe)

processPipeTerm

protected void processPipeTerm()

processPipeTermAck

protected void processPipeTermAck()

processTermReq

protected void processTermReq(zmq.Own object)

processTerm

protected void processTerm(int linger)

processTermAck

protected void processTermAck()

processReap

protected void processReap(SocketBase socket)

processReaped

protected void processReaped()

processSeqnum

protected void processSeqnum()