Package | Description |
---|---|
zmq |
Modifier and Type | Method and Description |
---|---|
static Msg |
ZMQ.msgInit() |
static Msg |
ZMQ.msgInitWithSize(int messageSize) |
Msg |
IMsgSource.pullMsg() |
Msg |
Msg.put(byte b) |
Msg |
Msg.put(byte[] src) |
Msg |
Msg.put(byte[] src,
int off,
int len) |
Msg |
Msg.put(ByteBuffer src) |
Msg |
Msg.put(int index,
byte b) |
Msg |
SocketBase.recv(int flags) |
static Msg |
ZMQ.recv(SocketBase s,
int flags) |
static Msg |
ZMQ.recvMsg(SocketBase s,
int flags) |
protected Msg |
Pub.xrecv() |
protected Msg |
SocketBase.xrecv() |
protected Msg |
Req.xrecv() |
protected Msg |
Dealer.xrecv() |
protected Msg |
Pair.xrecv() |
protected Msg |
Router.xrecv() |
protected Msg |
Rep.xrecv() |
protected Msg |
XSub.xrecv() |
Modifier and Type | Method and Description |
---|---|
static int |
ZMQ.getMessageOption(Msg msg,
int option) |
static int |
ZMQ.msgSize(Msg msg) |
protected void |
DecoderBase.nextStep(Msg msg,
int state) |
protected void |
EncoderBase.nextStep(Msg msg,
int state,
boolean beginning) |
int |
IMsgSink.pushMsg(Msg msg) |
int |
Req.ReqSession.pushMsg(Msg msg) |
int |
StreamEngine.pushMsg(Msg msg) |
boolean |
SocketBase.send(Msg msg,
int flags) |
boolean |
LB.send(Msg msg,
ValueReference<Integer> errno) |
static int |
ZMQ.send(SocketBase s,
Msg msg,
int flags) |
static int |
ZMQ.sendMsg(SocketBase s,
Msg msg,
int flags) |
protected boolean |
SocketBase.xsend(Msg msg) |
boolean |
Push.xsend(Msg msg) |
boolean |
Req.xsend(Msg msg) |
protected boolean |
Dealer.xsend(Msg msg) |
protected boolean |
Pair.xsend(Msg msg) |
protected boolean |
Sub.xsend(Msg msg) |
protected boolean |
Router.xsend(Msg msg) |
protected boolean |
Rep.xsend(Msg msg) |
protected boolean |
XSub.xsend(Msg msg) |
Constructor and Description |
---|
Msg(Msg m) |
Copyright © 2016. All rights reserved.