Package | Description |
---|---|
org.zeromq |
Provides high-level bindings for ØMQ.
|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.io | |
zmq.io.coder | |
zmq.io.coder.raw | |
zmq.io.coder.v2 | |
zmq.io.mechanism | |
zmq.io.mechanism.curve | |
zmq.io.mechanism.gssapi | |
zmq.io.mechanism.plain | |
zmq.msg |
Provides utility for message allocation within ØMQ.
|
zmq.pipe | |
zmq.socket | |
zmq.socket.clientserver | |
zmq.socket.pipeline | |
zmq.socket.pubsub | |
zmq.socket.radiodish | |
zmq.socket.reqrep | |
zmq.socket.scattergather | |
zmq.util |
Constructor and Description |
---|
ZFrame(Msg msg)
Class Constructor
Uses internal Msg class to access routingId
|
Modifier and Type | Class and Description |
---|---|
static class |
Msg.Builder |
Modifier and Type | Field and Description |
---|---|
Msg |
Options.disconnectMsg |
Msg |
Options.helloMsg |
Msg |
Options.hiccupMsg |
Modifier and Type | Method and Description |
---|---|
Msg |
Msg.Builder.build() |
static Msg |
ZMQ.msgInit() |
static Msg |
ZMQ.msgInitWithSize(int messageSize) |
Msg |
Msg.put(byte b) |
Msg |
Msg.put(byte[] src) |
Msg |
Msg.put(byte[] src,
int off,
int len) |
Msg |
Msg.Builder.put(byte[] src,
int off,
int len) |
Msg |
Msg.put(java.nio.ByteBuffer src) |
Msg |
Msg.put(java.nio.ByteBuffer src,
int off,
int len) |
Msg |
Msg.Builder.put(java.nio.ByteBuffer src,
int off,
int len) |
Msg |
Msg.put(int b) |
protected Msg |
Msg.put(int index,
byte b) |
protected Msg |
Msg.Builder.put(int index,
byte b) |
Msg |
Msg.putShortString(java.lang.String data)
Puts a string into the message, prefixed with its length.
|
Msg |
Msg.Builder.putShortString(java.lang.String data) |
Msg |
SocketBase.recv(int flags) |
Msg |
SocketBase.recv(int flags,
java.util.concurrent.atomic.AtomicBoolean canceled) |
static Msg |
ZMQ.recv(SocketBase s,
int flags) |
static Msg |
ZMQ.recvMsg(SocketBase s,
int flags) |
Msg |
Msg.setMetadata(Metadata metadata) |
protected Msg |
SocketBase.xrecv() |
Modifier and Type | Method and Description |
---|---|
private boolean |
Proxy.capture(SocketBase capture,
Msg msg,
int more) |
private void |
SocketBase.extractFlags(Msg msg) |
java.lang.String |
ZMQ.getMessageGroup(Msg msg) |
static java.lang.String |
ZMQ.getMessageMetadata(Msg msg,
java.lang.String property) |
static int |
ZMQ.getMessageOption(Msg msg,
int option) |
int |
ZMQ.getMessageRoutingId(Msg msg) |
static int |
ZMQ.msgSize(Msg msg) |
boolean |
SocketBase.send(Msg msg,
int flags) |
boolean |
SocketBase.send(Msg msg,
int flags,
java.util.concurrent.atomic.AtomicBoolean canceled) |
static int |
ZMQ.send(SocketBase s,
Msg msg,
int flags) |
static int |
ZMQ.sendMsg(SocketBase s,
Msg msg,
int flags) |
boolean |
ZMQ.setMessageGroup(Msg msg,
java.lang.String group) |
boolean |
ZMQ.setMessageRoutingId(Msg msg,
int routingId) |
protected boolean |
SocketBase.xsend(Msg msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
ZObject.processHiccup(YPipeBase<Msg> hiccupPipe) |
protected void |
ZObject.sendHiccup(Pipe destination,
YPipeBase<Msg> pipe) |
Constructor and Description |
---|
Msg(Msg m) |
Msg(Msg src,
java.io.ByteArrayOutputStream out) |
Modifier and Type | Field and Description |
---|---|
private Function<Msg,java.lang.Boolean> |
StreamEngine.decodeAndPush |
private Supplier<Msg> |
StreamEngine.nextHandshakeCommand |
private Supplier<Msg> |
StreamEngine.nextIdentity |
private Supplier<Msg> |
StreamEngine.nextMsg |
private Function<Msg,java.lang.Boolean> |
StreamEngine.processHandshakeCommand |
private Function<Msg,java.lang.Boolean> |
StreamEngine.processIdentity |
private Function<Msg,java.lang.Boolean> |
StreamEngine.processMsg |
private Supplier<Msg> |
StreamEngine.producePingMessage |
private Supplier<Msg> |
StreamEngine.pullAndEncode |
private Supplier<Msg> |
StreamEngine.pullMsgFromSession |
private Function<Msg,java.lang.Boolean> |
StreamEngine.pushMsgToSession |
private Function<Msg,java.lang.Boolean> |
StreamEngine.pushOneThenDecodeAndPush |
private Function<Msg,java.lang.Boolean> |
StreamEngine.pushRawMsgToSession |
private Function<Msg,java.lang.Boolean> |
StreamEngine.writeCredential |
Modifier and Type | Method and Description |
---|---|
Msg |
StreamEngine.ProducePongMessage.get() |
private Msg |
StreamEngine.identityMsg() |
private Msg |
StreamEngine.nextHandshakeCommand() |
private Msg |
StreamEngine.producePingMessage() |
private Msg |
StreamEngine.producePongMessage(byte[] pingContext) |
private Msg |
StreamEngine.pullAndEncode() |
protected Msg |
HelloMsgSession.pullMsg() |
protected Msg |
SessionBase.pullMsg() |
private Msg |
StreamEngine.pullMsgFromSession() |
Msg |
SessionBase.readZapMsg() |
Modifier and Type | Method and Description |
---|---|
private boolean |
StreamEngine.decodeAndPush(Msg msg) |
private boolean |
StreamEngine.processCommand(Msg msg) |
private boolean |
StreamEngine.processHandshakeCommand(Msg msg) |
private boolean |
StreamEngine.processHeartbeatMessage(Msg msg) |
private boolean |
StreamEngine.processIdentityMsg(Msg msg) |
protected boolean |
SessionBase.pushMsg(Msg msg) |
private boolean |
StreamEngine.pushMsgToSession(Msg msg) |
private boolean |
StreamEngine.pushOneThenDecodeAndPush(Msg msg) |
private boolean |
StreamEngine.pushRawMsgToSession(Msg msg) |
int |
Metadata.read(Msg msg,
int offset,
Metadata.ParseListener listener) |
static boolean |
Msgs.startsWith(Msg msg,
java.lang.String data,
boolean includeLength)
Checks if the message starts with the given string.
|
private boolean |
StreamEngine.writeCredential(Msg msg) |
boolean |
SessionBase.writeZapMsg(Msg msg) |
Modifier and Type | Field and Description |
---|---|
protected Msg |
EncoderBase.inProgress |
protected Msg |
Decoder.inProgress |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Decoder.allocate(int size) |
Msg |
Decoder.msg() |
Msg |
IDecoder.msg() |
Modifier and Type | Method and Description |
---|---|
void |
EncoderBase.loadMsg(Msg msg) |
void |
IEncoder.loadMsg(Msg msg) |
protected void |
DecoderBase.nextStep(Msg msg,
IDecoder.Step next) |
protected void |
EncoderBase.nextStep(Msg msg,
java.lang.Runnable state,
boolean beginning) |
Modifier and Type | Field and Description |
---|---|
protected Msg |
RawDecoder.inProgress |
Modifier and Type | Method and Description |
---|---|
Msg |
RawDecoder.msg() |
Modifier and Type | Method and Description |
---|---|
protected Msg |
V2Decoder.allocate(int size) |
Modifier and Type | Method and Description |
---|---|
Msg |
Mechanism.decode(Msg msg) |
Msg |
Mechanism.encode(Msg msg) |
Msg |
Mechanism.peerIdentity() |
Modifier and Type | Method and Description |
---|---|
protected void |
Mechanism.addProperty(Msg msg,
java.lang.String name,
byte[] value) |
protected void |
Mechanism.addProperty(Msg msg,
java.lang.String name,
java.lang.String value) |
protected boolean |
Mechanism.compare(Msg msg,
java.lang.String data,
boolean includeLength) |
Msg |
Mechanism.decode(Msg msg) |
Msg |
Mechanism.encode(Msg msg) |
abstract int |
Mechanism.nextHandshakeCommand(Msg msg) |
int |
NullMechanism.nextHandshakeCommand(Msg msg) |
protected int |
Mechanism.parseErrorMessage(Msg msg) |
protected int |
Mechanism.parseMetadata(Msg msg,
int offset,
boolean zapFlag) |
private int |
NullMechanism.processErrorCommand(Msg msg) |
abstract int |
Mechanism.processHandshakeCommand(Msg msg) |
int |
NullMechanism.processHandshakeCommand(Msg msg) |
private int |
NullMechanism.processReadyCommand(Msg msg) |
Modifier and Type | Method and Description |
---|---|
Msg |
CurveServerMechanism.decode(Msg msg) |
Msg |
CurveClientMechanism.decode(Msg msg) |
Msg |
CurveServerMechanism.encode(Msg msg) |
Msg |
CurveClientMechanism.encode(Msg msg) |
Modifier and Type | Method and Description |
---|---|
Msg |
CurveServerMechanism.decode(Msg msg) |
Msg |
CurveClientMechanism.decode(Msg msg) |
Msg |
CurveServerMechanism.encode(Msg msg) |
Msg |
CurveClientMechanism.encode(Msg msg) |
int |
CurveServerMechanism.nextHandshakeCommand(Msg msg) |
int |
CurveClientMechanism.nextHandshakeCommand(Msg msg) |
private int |
CurveClientMechanism.processError(Msg msg) |
int |
CurveServerMechanism.processHandshakeCommand(Msg msg) |
int |
CurveClientMechanism.processHandshakeCommand(Msg msg) |
private int |
CurveServerMechanism.processHello(Msg msg) |
private int |
CurveServerMechanism.processInitiate(Msg msg) |
private int |
CurveClientMechanism.processReady(Msg msg) |
private int |
CurveClientMechanism.processWelcome(Msg msg) |
private int |
CurveServerMechanism.produceError(Msg msg) |
private int |
CurveClientMechanism.produceHello(Msg msg) |
private int |
CurveClientMechanism.produceInitiate(Msg msg) |
private int |
CurveServerMechanism.produceReady(Msg msg) |
private int |
CurveServerMechanism.produceWelcome(Msg msg) |
Modifier and Type | Method and Description |
---|---|
int |
GssapiClientMechanism.nextHandshakeCommand(Msg msg) |
int |
GssapiServerMechanism.nextHandshakeCommand(Msg msg) |
int |
GssapiClientMechanism.processHandshakeCommand(Msg msg) |
int |
GssapiServerMechanism.processHandshakeCommand(Msg msg) |
Modifier and Type | Method and Description |
---|---|
int |
PlainClientMechanism.nextHandshakeCommand(Msg msg) |
int |
PlainServerMechanism.nextHandshakeCommand(Msg msg) |
private int |
PlainClientMechanism.processError(Msg msg) |
int |
PlainClientMechanism.processHandshakeCommand(Msg msg) |
int |
PlainServerMechanism.processHandshakeCommand(Msg msg) |
private int |
PlainClientMechanism.processReady(Msg msg) |
private int |
PlainClientMechanism.processWelcome(Msg msg) |
private int |
PlainServerMechanism.produceError(Msg msg) |
private int |
PlainClientMechanism.produceHello(Msg msg) |
private int |
PlainServerMechanism.produceHello(Msg msg) |
private int |
PlainClientMechanism.produceInitiate(Msg msg) |
private int |
PlainServerMechanism.produceInitiate(Msg msg) |
private int |
PlainServerMechanism.produceReady(Msg msg) |
private int |
PlainServerMechanism.produceWelcome(Msg msg) |
Modifier and Type | Method and Description |
---|---|
Msg |
MsgAllocator.allocate(int size) |
Msg |
MsgAllocatorThreshold.allocate(int size) |
Msg |
MsgAllocatorHeap.allocate(int size) |
Msg |
MsgAllocatorDirect.allocate(int size) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
DBuffer<T extends Msg> |
class |
YPipeConflate<T extends Msg> |
Modifier and Type | Field and Description |
---|---|
private T |
DBuffer.back |
private Msg |
Pipe.disconnectMsg |
private T |
DBuffer.front |
Modifier and Type | Field and Description |
---|---|
private YPipeBase<Msg> |
Pipe.inpipe |
private YPipeBase<Msg> |
Pipe.outpipe |
Modifier and Type | Method and Description |
---|---|
Msg |
Pipe.read() |
Modifier and Type | Method and Description |
---|---|
private static boolean |
Pipe.isDelimiter(Msg msg) |
void |
Pipe.sendHiccupMsg(Msg hiccupMsg) |
void |
Pipe.setDisconnectMsg(Msg msg) |
boolean |
Pipe.write(Msg msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
Pipe.processHiccup(YPipeBase<Msg> pipe) |
Constructor and Description |
---|
Pipe(ZObject parent,
YPipeBase<Msg> inpipe,
YPipeBase<Msg> outpipe,
int inhwm,
int outhwm,
boolean conflate) |
Pipe(ZObject parent,
YPipeBase<Msg> inpipe,
YPipeBase<Msg> outpipe,
int inhwm,
int outhwm,
boolean conflate) |
Modifier and Type | Field and Description |
---|---|
private Msg |
Stream.prefetchedId |
private Msg |
Stream.prefetchedMsg |
Modifier and Type | Method and Description |
---|---|
Msg |
FQ.recv(Errno errno) |
Msg |
FQ.recvPipe(Errno errno,
ValueReference<Pipe> pipe) |
Msg |
Stream.xrecv() |
protected Msg |
Channel.xrecv() |
protected Msg |
Pair.xrecv() |
Modifier and Type | Method and Description |
---|---|
boolean |
LB.sendpipe(Msg msg,
Errno errno,
ValueReference<Pipe> pipe) |
protected boolean |
Stream.xsend(Msg msg) |
protected boolean |
Channel.xsend(Msg msg) |
protected boolean |
Pair.xsend(Msg msg) |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Server.xrecv() |
protected Msg |
Client.xrecv() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
Server.xsend(Msg msg) |
protected boolean |
Client.xsend(Msg msg) |
Modifier and Type | Method and Description |
---|---|
Msg |
Pull.xrecv() |
Modifier and Type | Method and Description |
---|---|
boolean |
Push.xsend(Msg msg) |
Modifier and Type | Field and Description |
---|---|
private Msg |
XSub.message |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Pub.xrecv() |
protected Msg |
XPub.xrecv() |
protected Msg |
XSub.xrecv() |
Modifier and Type | Method and Description |
---|---|
boolean |
Trie.add(Msg msg,
int start,
int size) |
boolean |
Mtrie.add(Msg msg,
Pipe pipe) |
private boolean |
Mtrie.addHelper(Msg msg,
int start,
int size,
Pipe pipe) |
private void |
Dist.distribute(Msg msg) |
private boolean |
XSub.match(Msg msg) |
boolean |
Trie.rm(Msg msg,
int start,
int size) |
boolean |
Mtrie.rm(Msg msg,
Pipe pipe) |
private boolean |
Mtrie.rmHelper(Msg msg,
int start,
int size,
Pipe pipe) |
boolean |
Dist.sendToAll(Msg msg) |
boolean |
Dist.sendToMatching(Msg msg) |
private boolean |
Dist.write(Pipe pipe,
Msg msg) |
protected boolean |
XPub.xsend(Msg msg) |
protected boolean |
Sub.xsend(Msg msg) |
protected boolean |
XSub.xsend(Msg msg) |
Modifier and Type | Field and Description |
---|---|
private Msg |
Radio.RadioSession.pending |
private Msg |
Dish.pendingMsg |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Radio.RadioSession.pullMsg() |
protected Msg |
Dish.DishSession.pullMsg() |
protected Msg |
Radio.xrecv() |
protected Msg |
Dish.xrecv() |
private Msg |
Dish.xxrecv() |
Modifier and Type | Method and Description |
---|---|
boolean |
Radio.RadioSession.pushMsg(Msg msg) |
boolean |
Dish.DishSession.pushMsg(Msg msg) |
protected boolean |
Radio.xsend(Msg msg) |
protected boolean |
Dish.xsend(Msg msg) |
Modifier and Type | Field and Description |
---|---|
private Msg |
Router.prefetchedId |
private Msg |
Router.prefetchedMsg |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Dealer.recvpipe(ValueReference<Pipe> pipe) |
private Msg |
Req.recvReplyPipe() |
protected Msg |
Rep.xrecv() |
protected Msg |
Router.xrecv() |
protected Msg |
Dealer.xrecv() |
protected Msg |
Req.xrecv() |
Modifier and Type | Method and Description |
---|---|
boolean |
Req.ReqSession.pushMsg(Msg msg) |
protected boolean |
Dealer.sendpipe(Msg msg,
ValueReference<Pipe> pipe) |
protected boolean |
Rep.xsend(Msg msg) |
protected boolean |
Router.xsend(Msg msg) |
protected boolean |
Dealer.xsend(Msg msg) |
boolean |
Req.xsend(Msg msg) |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Gather.xrecv() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
Scatter.xsend(Msg msg) |
Modifier and Type | Method and Description |
---|---|
static Msg |
Wire.putUInt16(Msg msg,
int value) |
static Msg |
Wire.putUInt32(Msg msg,
int value) |
Modifier and Type | Method and Description |
---|---|
static Blob |
Blob.createBlob(Msg msg) |
static int |
Wire.getUInt32(Msg msg,
int offset) |
static long |
Wire.getUInt64(Msg msg,
int offset) |
static Msg |
Wire.putUInt16(Msg msg,
int value) |
static Msg |
Wire.putUInt32(Msg msg,
int value) |