Package | Description |
---|---|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.io | |
zmq.io.coder | |
zmq.io.coder.raw | |
zmq.socket | |
zmq.socket.reqrep |
Modifier and Type | Method and Description |
---|---|
private byte[] |
Options.setCurveKey(int option,
java.lang.Object optval,
ValueReference<java.lang.Boolean> result) |
Modifier and Type | Field and Description |
---|---|
private ValueReference<java.nio.ByteBuffer> |
StreamEngine.outpos |
Modifier and Type | Method and Description |
---|---|
IDecoder.Step.Result |
DecoderBase.decode(java.nio.ByteBuffer data,
int size,
ValueReference<java.lang.Integer> processed) |
IDecoder.Step.Result |
IDecoder.decode(java.nio.ByteBuffer buffer,
int size,
ValueReference<java.lang.Integer> processed) |
int |
EncoderBase.encode(ValueReference<java.nio.ByteBuffer> data,
int size) |
int |
IEncoder.encode(ValueReference<java.nio.ByteBuffer> data,
int size) |
Modifier and Type | Method and Description |
---|---|
IDecoder.Step.Result |
RawDecoder.decode(java.nio.ByteBuffer buffer,
int size,
ValueReference<java.lang.Integer> processed) |
Modifier and Type | Method and Description |
---|---|
Msg |
FQ.recvPipe(Errno errno,
ValueReference<Pipe> pipe) |
boolean |
LB.sendpipe(Msg msg,
Errno errno,
ValueReference<Pipe> pipe) |
Modifier and Type | Field and Description |
---|---|
private ValueReference<Pipe> |
Req.replyPipe |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Dealer.recvpipe(ValueReference<Pipe> pipe) |
protected boolean |
Dealer.sendpipe(Msg msg,
ValueReference<Pipe> pipe) |