Package | Description |
---|---|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.io | |
zmq.io.net | |
zmq.io.net.ipc | |
zmq.io.net.norm | |
zmq.io.net.pgm | |
zmq.io.net.tcp | |
zmq.io.net.tipc | |
zmq.socket | |
zmq.socket.radiodish | |
zmq.socket.reqrep |
Modifier and Type | Field and Description |
---|---|
private java.util.List<IOThread> |
Ctx.ioThreads |
Modifier and Type | Method and Description |
---|---|
(package private) IOThread |
Ctx.chooseIoThread(long affinity) |
protected IOThread |
ZObject.chooseIoThread(long affinity) |
Constructor and Description |
---|
Own(IOThread ioThread,
Options options) |
Modifier and Type | Field and Description |
---|---|
private IOThread |
SessionBase.ioThread |
Modifier and Type | Method and Description |
---|---|
void |
StreamEngine.plug(IOThread ioThread,
SessionBase session) |
void |
EngineNotImplemented.plug(IOThread ioThread,
SessionBase session) |
void |
IEngine.plug(IOThread ioThread,
SessionBase session) |
Constructor and Description |
---|
HelloMsgSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
IOObject(IOThread ioThread,
IPollEvents handler) |
SessionBase(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Modifier and Type | Method and Description |
---|---|
Listener |
NetProtocol.getListener(IOThread ioThread,
SocketBase socket,
Options options) |
Constructor and Description |
---|
Listener(IOThread ioThread,
SocketBase socket,
Options options) |
Constructor and Description |
---|
IpcConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
boolean wait) |
IpcListener(IOThread ioThread,
SocketBase socket,
Options options) |
Constructor and Description |
---|
NormEngine(IOThread ioThread,
Options options) |
Constructor and Description |
---|
PgmReceiver(IOThread ioThread,
Options options) |
PgmSender(IOThread ioThread,
Options options) |
Constructor and Description |
---|
SocksConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
Address proxyAddr,
boolean delayedStart) |
TcpConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
boolean delayedStart) |
TcpListener(IOThread ioThread,
SocketBase socket,
Options options) |
Constructor and Description |
---|
TipcConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
boolean wait) |
TipcListener(IOThread ioThread,
SocketBase socket,
Options options) |
Modifier and Type | Method and Description |
---|---|
SessionBase |
Sockets.create(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
static SessionBase |
Sockets.createSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Constructor and Description |
---|
DishSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
RadioSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Constructor and Description |
---|
ReqSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |