Uses of Class
zmq.Msg
Packages that use Msg
Package
Description
Provides low-level bindings for ØMQ.
Provides utility for message allocation within ØMQ.
-
Uses of Msg in zmq
Modifier and TypeMethodDescriptionMsg.Builder.build()
static Msg
ZMQ.msgInit()
static Msg
ZMQ.msgInitWithSize
(int messageSize) Msg.Builder.put
(byte[] src, int off, int len) protected Msg
Msg.Builder.put
(int index, byte b) Msg.Builder.put
(ByteBuffer src, int off, int len) Msg.put
(byte b) Msg.put
(byte[] src) Msg.put
(byte[] src, int off, int len) Msg.put
(int b) protected Msg
Msg.put
(int index, byte b) Msg.put
(ByteBuffer src) Msg.put
(ByteBuffer src, int off, int len) Msg.Builder.putShortString
(String data) Msg.putShortString
(String data) Puts a string into the message, prefixed with its length.final Msg
SocketBase.recv
(int flags) static Msg
ZMQ.recv
(SocketBase s, int flags) static Msg
ZMQ.recvMsg
(SocketBase s, int flags) Msg.setMetadata
(Metadata metadata) protected Msg
SocketBase.xrecv()
Modifier and TypeMethodDescriptionprivate boolean
Proxy.capture
(SocketBase capture, Msg msg, int more) private void
SocketBase.extractFlags
(Msg msg) static String
ZMQ.getMessageMetadata
(Msg msg, String property) static int
ZMQ.getMessageOption
(Msg msg, int option) static int
final boolean
static int
ZMQ.send
(SocketBase s, Msg msg, int flags) static int
ZMQ.sendMsg
(SocketBase s, Msg msg, int flags) protected boolean
Modifier and TypeMethodDescriptionprotected void
ZObject.processHiccup
(YPipeBase<Msg> hiccupPipe) protected final void
ZObject.sendHiccup
(Pipe destination, YPipeBase<Msg> pipe) -
Uses of Msg in zmq.io
Modifier and TypeFieldDescriptionStreamEngine.decodeAndPush
StreamEngine.nextHandshakeCommand
StreamEngine.nextIdentity
StreamEngine.nextMsg
StreamEngine.processHandshakeCommand
StreamEngine.processIdentity
StreamEngine.processMsg
StreamEngine.producePingMessage
StreamEngine.pullAndEncode
StreamEngine.pullMsgFromSession
StreamEngine.pushMsgToSession
StreamEngine.pushOneThenDecodeAndPush
StreamEngine.pushRawMsgToSession
StreamEngine.writeCredential
Modifier and TypeMethodDescriptionStreamEngine.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
SessionBase.pullMsg()
private Msg
StreamEngine.pullMsgFromSession()
SessionBase.readZapMsg()
Modifier and TypeMethodDescriptionprivate 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
private boolean
StreamEngine.pushMsgToSession
(Msg msg) private boolean
StreamEngine.pushOneThenDecodeAndPush
(Msg msg) private boolean
StreamEngine.pushRawMsgToSession
(Msg msg) final int
Metadata.read
(Msg msg, int offset, Metadata.ParseListener listener) static boolean
Msgs.startsWith
(Msg msg, String data, boolean includeLength) Checks if the message starts with the given string.private boolean
StreamEngine.writeCredential
(Msg msg) boolean
SessionBase.writeZapMsg
(Msg msg) -
Uses of Msg in zmq.io.coder
Fields in zmq.io.coder declared as MsgModifier and TypeFieldDescriptionprotected Msg
Decoder.inProgress
protected Msg
EncoderBase.inProgress
Methods in zmq.io.coder that return MsgModifier and TypeMethodDescriptionprotected Msg
Decoder.allocate
(int size) Decoder.msg()
IDecoder.msg()
Methods in zmq.io.coder with parameters of type Msg -
Uses of Msg in zmq.io.coder.raw
Fields in zmq.io.coder.raw declared as MsgMethods in zmq.io.coder.raw that return Msg -
Uses of Msg in zmq.io.coder.v2
Methods in zmq.io.coder.v2 that return Msg -
Uses of Msg in zmq.io.mechanism
Methods in zmq.io.mechanism that return MsgMethods in zmq.io.mechanism with parameters of type MsgModifier and TypeMethodDescriptionprotected final void
Mechanism.addProperty
(Msg msg, String name, byte[] value) protected final void
Mechanism.addProperty
(Msg msg, String name, String value) protected boolean
abstract int
Mechanism.nextHandshakeCommand
(Msg msg) int
NullMechanism.nextHandshakeCommand
(Msg msg) protected final 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) -
Uses of Msg in zmq.io.mechanism.curve
Methods in zmq.io.mechanism.curve that return MsgModifier and TypeMethodDescriptionMethods in zmq.io.mechanism.curve with parameters of type MsgModifier and TypeMethodDescriptionint
CurveClientMechanism.nextHandshakeCommand
(Msg msg) int
CurveServerMechanism.nextHandshakeCommand
(Msg msg) private int
CurveClientMechanism.processError
(Msg msg) int
CurveClientMechanism.processHandshakeCommand
(Msg msg) int
CurveServerMechanism.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) -
Uses of Msg in zmq.io.mechanism.gssapi
Methods in zmq.io.mechanism.gssapi with parameters of type MsgModifier and TypeMethodDescriptionint
GssapiClientMechanism.nextHandshakeCommand
(Msg msg) int
GssapiServerMechanism.nextHandshakeCommand
(Msg msg) int
GssapiClientMechanism.processHandshakeCommand
(Msg msg) int
GssapiServerMechanism.processHandshakeCommand
(Msg msg) -
Uses of Msg in zmq.io.mechanism.plain
Methods in zmq.io.mechanism.plain with parameters of type MsgModifier and TypeMethodDescriptionint
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) -
Uses of Msg in zmq.msg
-
Uses of Msg in zmq.pipe
-
Uses of Msg in zmq.socket
Fields in zmq.socket declared as MsgModifier and TypeFieldDescriptionprivate Msg
Stream.prefetchedId
private Msg
Stream.prefetchedMsg
Methods in zmq.socket that return MsgModifier and TypeMethodDescriptionFQ.recvPipe
(Errno errno, ValueReference<Pipe> pipe) protected Msg
Pair.xrecv()
Stream.xrecv()
Methods in zmq.socket with parameters of type Msg -
Uses of Msg in zmq.socket.pipeline
Methods in zmq.socket.pipeline that return MsgMethods in zmq.socket.pipeline with parameters of type Msg -
Uses of Msg in zmq.socket.pubsub
Fields in zmq.socket.pubsub declared as MsgMethods in zmq.socket.pubsub that return MsgModifier and TypeMethodDescriptionprotected Msg
Pub.xrecv()
protected Msg
XPub.xrecv()
protected Msg
XSub.xrecv()
Methods in zmq.socket.pubsub with parameters of type MsgModifier and TypeMethodDescriptionboolean
boolean
private boolean
private void
Dist.distribute
(Msg msg) private boolean
boolean
boolean
private boolean
boolean
boolean
Dist.sendToMatching
(Msg msg) private boolean
protected boolean
protected boolean
protected boolean
-
Uses of Msg in zmq.socket.reqrep
Fields in zmq.socket.reqrep declared as MsgModifier and TypeFieldDescriptionprivate Msg
Router.prefetchedId
private Msg
Router.prefetchedMsg
Methods in zmq.socket.reqrep that return MsgModifier and TypeMethodDescriptionprotected final Msg
Dealer.recvpipe
(ValueReference<Pipe> pipe) private Msg
Req.recvReplyPipe()
protected Msg
Dealer.xrecv()
protected Msg
Rep.xrecv()
protected Msg
Req.xrecv()
protected Msg
Router.xrecv()
Methods in zmq.socket.reqrep with parameters of type Msg -
Uses of Msg in zmq.util