zmq

Class Reaper

java.lang.Object

zmq.ZObject

zmq.Reaper

All Implemented Interfaces:

Closeable, AutoCloseable, IPollEvents

public class Reaper
extends ZObject
implements IPollEvents, Closeable

Constructor Summary

Constructors

Constructor and Description
Reaper(Ctx ctx, int tid)

Method Summary

Modifier and Type	Method and Description
void	acceptEvent()
void	close()
void	connectEvent()
Mailbox	getMailbox()
void	inEvent()
void	outEvent()
protected void	processReap(SocketBase socket)
protected void	processReaped()
protected void	processStop()
void	start()
void	stop()
void	timerEvent(int id)

Methods inherited from class zmq.ZObject

chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processBind, processCommand, processHiccup, processOwn, processPipeTerm, processPipeTermAck, processPlug, processSeqnum, processTerm, processTermAck, processTermReq, 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, toString, wait, wait, wait

Constructor Detail

Reaper

public Reaper(Ctx ctx,
              int tid)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getMailbox

public Mailbox getMailbox()

start

public void start()

stop

public void stop()

inEvent

public void inEvent()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Specified by:

outEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents

timerEvent

public void timerEvent(int id)

Specified by:

timerEvent in interface IPollEvents

processStop

protected void processStop()

Overrides:

processStop in class ZObject

processReap

protected void processReap(SocketBase socket)

Overrides:

processReap in class ZObject

processReaped

protected void processReaped()

Overrides:

processReaped in class ZObject