Package | Description |
---|---|
org.zeromq | |
zmq |
Modifier and Type | Method and Description |
---|---|
SocketBase |
ZMQ.Socket.base()
DO NOT USE if you're trying to build a special proxy
|
Constructor and Description |
---|
Socket(SocketBase base) |
Modifier and Type | Class and Description |
---|---|
class |
Dealer |
class |
Pair |
class |
Pub |
class |
Push |
class |
Rep |
class |
Req |
class |
Router |
class |
Sub |
class |
XSub |
Modifier and Type | Method and Description |
---|---|
static SocketBase |
SocketBase.create(int type,
Ctx parent,
int tid,
int sid) |
SocketBase |
Ctx.createSocket(int type) |
SocketBase |
PollItem.getSocket() |
static SocketBase |
ZMQ.socket(Ctx ctx,
int type) |
Modifier and Type | Method and Description |
---|---|
static boolean |
ZMQ.bind(SocketBase s,
String addr) |
static void |
ZMQ.close(SocketBase s) |
static boolean |
ZMQ.connect(SocketBase s,
String addr) |
protected void |
ZObject.destroySocket(SocketBase socket) |
void |
Ctx.destroySocket(SocketBase socket) |
static boolean |
ZMQ.device(int device,
SocketBase insocket,
SocketBase outsocket)
Deprecated.
|
static boolean |
ZMQ.disconnect(SocketBase s,
String addr) |
static int |
ZMQ.getSocketOption(SocketBase s,
int opt) |
static Object |
ZMQ.getSocketOptionExt(SocketBase s,
int option) |
static boolean |
ZMQ.monitorSocket(SocketBase s,
String addr,
int events) |
protected void |
Reaper.processReap(SocketBase socket) |
protected void |
ZObject.processReap(SocketBase socket) |
static boolean |
Proxy.proxy(SocketBase frontend,
SocketBase backend,
SocketBase capture) |
static boolean |
ZMQ.proxy(SocketBase frontend,
SocketBase backend,
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 len,
int flags) |
static int |
ZMQ.send(SocketBase s,
Msg msg,
int flags) |
static int |
ZMQ.send(SocketBase s,
String str,
int flags) |
int |
ZMQ.sendiov(SocketBase s,
byte[][] a,
int count,
int flags) |
static int |
ZMQ.sendMsg(SocketBase s,
Msg msg,
int flags) |
protected void |
ZObject.sendReap(SocketBase socket) |
static void |
ZMQ.setSocketOption(SocketBase s,
int option,
Object optval) |
static boolean |
ZMQ.unbind(SocketBase s,
String addr) |
protected void |
ZObject.unregisterEndpoints(SocketBase socket) |
boolean |
ZMQ.Event.write(SocketBase s) |
Constructor and Description |
---|
DealerSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
IpcListener(IOThread ioThread,
SocketBase socket,
Options options) |
PairSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
PollItem(SocketBase socket) |
PollItem(SocketBase socket,
int ops) |
PubSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
PushSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
RepSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
ReqSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
RouterSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
SubSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
TcpListener(IOThread ioThread,
SocketBase socket,
Options options) |
XSubSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Copyright © 2023. All rights reserved.