Package | Description |
---|---|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.io | |
zmq.io.mechanism | |
zmq.io.mechanism.curve | |
zmq.io.mechanism.gssapi | |
zmq.io.mechanism.plain | |
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 | |
zmq.util |
Modifier and Type | Method and Description |
---|---|
static Address |
Utils.getPeerIpAddress(java.nio.channels.SocketChannel fd)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
private Address |
SessionBase.addr |
private Address |
StreamEngine.peerAddress |
Constructor and Description |
---|
HelloMsgSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
SessionBase(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Modifier and Type | Field and Description |
---|---|
private Address |
Mechanism.peerAddress |
Modifier and Type | Method and Description |
---|---|
abstract Mechanism |
Mechanisms.create(SessionBase session,
Address peerAddress,
Options options) |
Constructor and Description |
---|
Mechanism(SessionBase session,
Address peerAddress,
Options options) |
NullMechanism(SessionBase session,
Address peerAddress,
Options options) |
Constructor and Description |
---|
CurveServerMechanism(SessionBase session,
Address peerAddress,
Options options) |
Constructor and Description |
---|
GssapiServerMechanism(SessionBase session,
Address peerAddress,
Options options) |
Constructor and Description |
---|
PlainServerMechanism(SessionBase session,
Address peerAddress,
Options options) |
Modifier and Type | Method and Description |
---|---|
void |
NetProtocol.resolve(Address paddr,
boolean ipv6) |
Constructor and Description |
---|
IpcConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
boolean wait) |
Modifier and Type | Method and Description |
---|---|
boolean |
NormEngine.init(Address addr,
boolean b,
boolean c) |
Modifier and Type | Method and Description |
---|---|
boolean |
PgmReceiver.init(boolean udpEncapsulation,
Address addr) |
boolean |
PgmSender.init(boolean udpEncapsulation,
Address addr) |
Modifier and Type | Field and Description |
---|---|
private Address |
TcpConnecter.addr |
private Address |
SocksConnecter.proxyAddress |
Modifier and Type | Method and Description |
---|---|
static Address |
TcpUtils.getPeerIpAddress(java.nio.channels.SocketChannel channel) |
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) |
Constructor and Description |
---|
TipcConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
boolean wait) |
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) |
Modifier and Type | Method and Description |
---|---|
static Address |
Utils.getPeerIpAddress(java.nio.channels.SocketChannel fd) |