zmq

Class SocketBase

java.lang.Object

zmq.ZObject

zmq.SocketBase

All Implemented Interfaces:

IPollEvents

Direct Known Subclasses:

Dealer, Pair, Pub, Push, Router, XSub

public abstract class SocketBase
extends ZObject
implements IPollEvents

Field Summary

Fields

Modifier and Type	Field and Description
protected ValueReference<Integer>	errno
protected Options	options

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SocketBase(Ctx parent, int tid, int sid)

Method Summary

Methods

Modifier and Type	Method and Description
void	acceptEvent()
boolean	bind(String addr)
boolean	checkTag()
void	close()
boolean	connect(String addr)
void	connectEvent()
static SocketBase	create(int type, Ctx parent, int tid, int sid)
void	destroy()
int	errno()
void	eventAccepted(String addr, SelectableChannel ch)
void	eventAcceptFailed(String addr, int errno)
void	eventBindFailed(String addr, int errno)
void	eventClosed(String addr, SelectableChannel ch)
void	eventCloseFailed(String addr, int errno)
void	eventConnectDelayed(String addr, int errno)
void	eventConnected(String addr, SelectableChannel ch)
void	eventConnectRetried(String addr, int interval)
void	eventDisconnected(String addr, SelectableChannel ch)
void	eventListening(String addr, SelectableChannel ch)
SelectableChannel	getFD()
Mailbox	getMailbox()
int	getSocketOpt(int option)
Object	getsockoptx(int option)
void	hiccuped(zmq.Pipe pipe)
void	inEvent()
protected boolean	isTerminating()
protected void	launchChild(zmq.Own object)
boolean	monitor(String addr, int events)
protected void	monitorEvent(ZMQ.Event event)
void	outEvent()
void	pipeTerminated(zmq.Pipe pipe)
protected void	processBind(zmq.Pipe pipe)
protected void	processDestroy()
protected void	processOwn(zmq.Own object)
protected void	processSeqnum()
protected void	processStop()
protected void	processTerm(int linger)
protected void	processTermAck()
protected void	processTermReq(zmq.Own object)
void	readActivated(zmq.Pipe pipe)
Msg	recv(int flags)
void	registerTermAcks(int count)
boolean	send(Msg msg, int flags)
void	setSocketOpt(int option, Object optval)
void	startReaping(Poller poller)
void	stop()
protected void	stopMonitor()
protected void	termChild(zmq.Own object)
boolean	termEndpoint(String addr)
protected void	terminate()
void	timerEvent(int id)
String	toString()
String	typeString()
void	unregisterTermAck()
void	writeActivated(zmq.Pipe pipe)
protected abstract void	xattachPipe(zmq.Pipe pipe, boolean icanhasall)
protected boolean	xhasIn()
protected boolean	xhasOut()
protected void	xhiccuped(zmq.Pipe pipe)
protected abstract void	xpipeTerminated(zmq.Pipe pipe)
protected void	xreadActivated(zmq.Pipe pipe)
protected Msg	xrecv()
protected boolean	xsend(Msg msg)
protected boolean	xsetsockopt(int option, Object optval)
protected void	xwriteActivated(zmq.Pipe pipe)

Methods inherited from class zmq.ZObject

chooseIoThread, 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

Methods inherited from class java.lang.Object

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

Field Detail

errno

protected ValueReference<Integer> errno

options

protected final Options options

Constructor Detail

SocketBase

protected SocketBase(Ctx parent,
          int tid,
          int sid)

Method Detail

xattachPipe

protected abstract void xattachPipe(zmq.Pipe pipe,
               boolean icanhasall)

xpipeTerminated

protected abstract void xpipeTerminated(zmq.Pipe pipe)

checkTag

public boolean checkTag()

create

public static SocketBase create(int type,
                Ctx parent,
                int tid,
                int sid)

destroy

public void destroy()

getMailbox

public Mailbox getMailbox()

stop

public void stop()

setSocketOpt

public void setSocketOpt(int option,
                Object optval)

getSocketOpt

public int getSocketOpt(int option)

getsockoptx

public Object getsockoptx(int option)

bind

public boolean bind(String addr)

connect

public boolean connect(String addr)

termEndpoint

public boolean termEndpoint(String addr)

send

public boolean send(Msg msg,
           int flags)

recv

public Msg recv(int flags)

close

public void close()

startReaping

public void startReaping(Poller poller)

processStop

protected void processStop()

Overrides:

processStop in class ZObject

processBind

protected void processBind(zmq.Pipe pipe)

Overrides:

processBind in class ZObject

processTerm

protected void processTerm(int linger)

processDestroy

protected void processDestroy()

xsetsockopt

protected boolean xsetsockopt(int option,
                  Object optval)

xhasOut

protected boolean xhasOut()

xsend

protected boolean xsend(Msg msg)

xhasIn

protected boolean xhasIn()

xrecv

protected Msg xrecv()

xreadActivated

protected void xreadActivated(zmq.Pipe pipe)

xwriteActivated

protected void xwriteActivated(zmq.Pipe pipe)

xhiccuped

protected void xhiccuped(zmq.Pipe pipe)

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

readActivated

public void readActivated(zmq.Pipe pipe)

writeActivated

public void writeActivated(zmq.Pipe pipe)

hiccuped

public void hiccuped(zmq.Pipe pipe)

pipeTerminated

public void pipeTerminated(zmq.Pipe pipe)

monitor

public boolean monitor(String addr,
              int events)

eventConnected

public void eventConnected(String addr,
                  SelectableChannel ch)

eventConnectDelayed

public void eventConnectDelayed(String addr,
                       int errno)

eventConnectRetried

public void eventConnectRetried(String addr,
                       int interval)

eventListening

public void eventListening(String addr,
                  SelectableChannel ch)

eventBindFailed

public void eventBindFailed(String addr,
                   int errno)

eventAccepted

public void eventAccepted(String addr,
                 SelectableChannel ch)

eventAcceptFailed

public void eventAcceptFailed(String addr,
                     int errno)

eventClosed

public void eventClosed(String addr,
               SelectableChannel ch)

eventCloseFailed

public void eventCloseFailed(String addr,
                    int errno)

eventDisconnected

public void eventDisconnected(String addr,
                     SelectableChannel ch)

monitorEvent

protected void monitorEvent(ZMQ.Event event)

stopMonitor

protected void stopMonitor()

toString

public String toString()

Overrides:

toString in class Object

getFD

public SelectableChannel getFD()

typeString

public String typeString()

errno

public int errno()

processSeqnum

protected void processSeqnum()

Overrides:

processSeqnum in class ZObject

launchChild

protected void launchChild(zmq.Own object)

termChild

protected void termChild(zmq.Own object)

processTermReq

protected void processTermReq(zmq.Own object)

Overrides:

processTermReq in class ZObject

processOwn

protected void processOwn(zmq.Own object)

Overrides:

processOwn in class ZObject

terminate

protected void terminate()

isTerminating

protected boolean isTerminating()

registerTermAcks

public void registerTermAcks(int count)

unregisterTermAck

public void unregisterTermAck()

processTermAck

protected void processTermAck()

Overrides:

processTermAck in class ZObject