Package | Description |
---|---|
org.zeromq |
Provides high-level bindings for ØMQ.
|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.io | |
zmq.io.net | |
zmq.io.net.ipc | |
zmq.io.net.tcp | |
zmq.io.net.tipc | |
zmq.poll | |
zmq.socket | |
zmq.socket.clientserver | |
zmq.socket.pipeline | |
zmq.socket.pubsub | |
zmq.socket.radiodish | |
zmq.socket.reqrep | |
zmq.socket.scattergather |
Modifier and Type | Field and Description |
---|---|
private SocketBase |
ZMQ.Socket.base |
(package private) SocketBase |
ZMQ.CancellationToken.socket |
private SocketBase |
ZSocket.socketBase |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<SocketBase> |
ManagedContext.sockets |
Modifier and Type | Method and Description |
---|---|
SocketBase |
ZMQ.Socket.base()
DO NOT USE if you're trying to build a special proxy
|
(package private) SocketBase |
ManagedContext.createSocket(int type) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
ManagedContext.destroy(SocketBase socketBase) |
Constructor and Description |
---|
CancellationToken(SocketBase socket) |
Socket(SocketBase base) |
Modifier and Type | Field and Description |
---|---|
private SocketBase |
SocketBase.monitorSocket |
SocketBase |
Ctx.Endpoint.socket |
Modifier and Type | Field and Description |
---|---|
private java.util.List<SocketBase> |
Ctx.sockets |
Modifier and Type | Method and Description |
---|---|
SocketBase |
Ctx.createSocket(int type) |
static SocketBase |
ZMQ.socket(Ctx ctx,
int type) |
Modifier and Type | Method and Description |
---|---|
static boolean |
ZMQ.bind(SocketBase s,
java.lang.String addr) |
private boolean |
Proxy.capture(SocketBase capture,
Msg msg,
int more) |
private static void |
ZMQ.checkSocket(SocketBase s) |
static void |
ZMQ.close(SocketBase s) |
static void |
ZMQ.closeZeroLinger(SocketBase s) |
static boolean |
ZMQ.connect(SocketBase s,
java.lang.String addr) |
private void |
Ctx.connectInprocSockets(SocketBase bindSocket,
Options bindOptions,
Ctx.PendingConnection pendingConnection,
Ctx.Side side) |
static int |
ZMQ.connectPeer(SocketBase s,
java.lang.String addr) |
protected void |
ZObject.connectPending(java.lang.String addr,
SocketBase bindSocket) |
(package private) void |
Ctx.connectPending(java.lang.String addr,
SocketBase bindSocket) |
protected void |
ZObject.destroySocket(SocketBase socket) |
(package private) void |
Ctx.destroySocket(SocketBase socket) |
static boolean |
ZMQ.device(int device,
SocketBase frontend,
SocketBase backend) |
static boolean |
ZMQ.disconnect(SocketBase s,
java.lang.String addr) |
static boolean |
ZMQ.disconnectPeer(SocketBase s,
int routingId) |
private boolean |
Proxy.forward(SocketBase from,
SocketBase to,
SocketBase capture) |
java.nio.channels.SelectableChannel |
ZMQ.Event.getChannel(SocketBase socket)
Resolve the channel that was associated with this event.
|
static int |
ZMQ.getSocketOption(SocketBase s,
int opt) |
static java.lang.Object |
ZMQ.getSocketOptionExt(SocketBase s,
int option) |
static boolean |
ZMQ.join(SocketBase s,
java.lang.String group) |
static boolean |
ZMQ.leave(SocketBase s,
java.lang.String group) |
static boolean |
ZMQ.monitorSocket(SocketBase s,
java.lang.String addr,
int events) |
private boolean |
Proxy.process(PollItem read,
PollItem write,
SocketBase frontend,
SocketBase backend) |
protected void |
ZObject.processReap(SocketBase socket) |
protected void |
Reaper.processReap(SocketBase socket) |
static boolean |
Proxy.proxy(SocketBase frontend,
SocketBase backend,
SocketBase capture) |
static boolean |
ZMQ.proxy(SocketBase frontend,
SocketBase backend,
SocketBase capture) |
static boolean |
Proxy.proxy(SocketBase frontend,
SocketBase backend,
SocketBase capture,
SocketBase control) |
static boolean |
ZMQ.proxy(SocketBase frontend,
SocketBase backend,
SocketBase capture,
SocketBase control) |
static ZMQ.Event |
ZMQ.Event.read(SocketBase s) |
static ZMQ.Event |
ZMQ.Event.read(SocketBase s,
int flags) |
static Msg |
ZMQ.recv(SocketBase s,
int flags) |
int |
ZMQ.recviov(SocketBase s,
byte[][] a,
int count,
int flags) |
static Msg |
ZMQ.recvMsg(SocketBase s,
int flags) |
static int |
ZMQ.send(SocketBase s,
byte[] buf,
int flags) |
static int |
ZMQ.send(SocketBase s,
byte[] buf,
int len,
int flags) |
static int |
ZMQ.send(SocketBase s,
Msg msg,
int flags) |
static int |
ZMQ.send(SocketBase s,
java.lang.String str,
int flags) |
protected void |
ZObject.sendInprocConnected(SocketBase socket) |
int |
ZMQ.sendiov(SocketBase s,
byte[][] a,
int count,
int flags) |
static boolean |
ZMQ.sendMsg(SocketBase socket,
byte[]... data) |
static int |
ZMQ.sendMsg(SocketBase s,
Msg msg,
int flags) |
protected void |
ZObject.sendReap(SocketBase socket) |
static boolean |
ZMQ.setSocketOption(SocketBase s,
int option,
java.lang.Object optval) |
private boolean |
Proxy.start(SocketBase frontend,
SocketBase backend,
SocketBase capture,
SocketBase control) |
static boolean |
ZMQ.unbind(SocketBase s,
java.lang.String addr) |
protected boolean |
ZObject.unregisterEndpoint(java.lang.String addr,
SocketBase socket) |
(package private) boolean |
Ctx.unregisterEndpoint(java.lang.String addr,
SocketBase socket) |
protected void |
ZObject.unregisterEndpoints(SocketBase socket) |
(package private) void |
Ctx.unregisterEndpoints(SocketBase socket) |
boolean |
ZMQ.Event.write(SocketBase s) |
Constructor and Description |
---|
Endpoint(SocketBase socket,
Options options) |
Modifier and Type | Field and Description |
---|---|
protected SocketBase |
SessionBase.socket |
private SocketBase |
StreamEngine.socket |
Modifier and Type | Method and Description |
---|---|
SocketBase |
SessionBase.getSocket() |
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 |
---|---|
protected SocketBase |
Listener.socket |
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 |
---|
IpcListener(IOThread ioThread,
SocketBase socket,
Options options) |
Modifier and Type | Field and Description |
---|---|
private SocketBase |
TcpConnecter.socket |
Constructor and Description |
---|
TcpListener(IOThread ioThread,
SocketBase socket,
Options options) |
Constructor and Description |
---|
TipcListener(IOThread ioThread,
SocketBase socket,
Options options) |
Modifier and Type | Field and Description |
---|---|
private SocketBase |
PollItem.socket |
Modifier and Type | Method and Description |
---|---|
SocketBase |
PollItem.getSocket() |
Constructor and Description |
---|
PollItem(SocketBase socket,
int ops) |
PollItem(SocketBase socket,
java.nio.channels.SelectableChannel channel,
int ops) |
Modifier and Type | Class and Description |
---|---|
class |
Channel |
class |
Pair |
class |
Peer |
class |
Raw |
class |
Stream |
Modifier and Type | Method and Description |
---|---|
(package private) abstract SocketBase |
Sockets.create(Ctx parent,
int tid,
int sid) |
static SocketBase |
Sockets.create(int socketType,
Ctx parent,
int tid,
int sid) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
Client |
class |
Server |
Modifier and Type | Class and Description |
---|---|
class |
Pull |
class |
Push |
Modifier and Type | Class and Description |
---|---|
class |
Pub |
class |
Sub |
class |
XPub |
class |
XSub |
Modifier and Type | Class and Description |
---|---|
class |
Dish |
class |
Radio |
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) |
Modifier and Type | Class and Description |
---|---|
class |
Dealer |
class |
Rep |
class |
Req |
class |
Router |
Constructor and Description |
---|
ReqSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Modifier and Type | Class and Description |
---|---|
class |
Gather |
class |
Scatter |