Uses of Class
zmq.Msg
-
Packages that use Msg Package Description 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.pipeline zmq.socket.pubsub zmq.socket.reqrep zmq.util -
-
Uses of Msg in zmq
Subclasses of Msg in zmq Modifier and Type Class Description static class
Msg.Builder
Methods in zmq that return Msg Modifier and Type Method Description Msg
Msg.Builder. build()
static Msg
ZMQ. msgInit()
static Msg
ZMQ. msgInitWithSize(int messageSize)
Msg
Msg.Builder. put(byte[] src, int off, int len)
protected Msg
Msg.Builder. put(int index, byte b)
Msg
Msg.Builder. put(java.nio.ByteBuffer src, int off, int len)
Msg
Msg. put(byte b)
Msg
Msg. put(byte[] src)
Msg
Msg. put(byte[] src, int off, int len)
Msg
Msg. put(int b)
protected Msg
Msg. put(int index, byte b)
Msg
Msg. put(java.nio.ByteBuffer src)
Msg
Msg. put(java.nio.ByteBuffer src, int off, int len)
Msg
Msg.Builder. putShortString(java.lang.String data)
Msg
Msg. putShortString(java.lang.String data)
Puts a string into the message, prefixed with its length.Msg
SocketBase. recv(int flags)
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()
Methods in zmq with parameters of type Msg Modifier and Type Method Description private boolean
Proxy. capture(SocketBase capture, Msg msg, int more)
private void
SocketBase. extractFlags(Msg msg)
static java.lang.String
ZMQ. getMessageMetadata(Msg msg, java.lang.String property)
static int
ZMQ. getMessageOption(Msg msg, int option)
static int
ZMQ. msgSize(Msg msg)
boolean
SocketBase. send(Msg msg, int flags)
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)
Method parameters in zmq with type arguments of type Msg Modifier and Type Method Description protected void
ZObject. processHiccup(YPipeBase<Msg> hiccupPipe)
protected void
ZObject. sendHiccup(Pipe destination, YPipeBase<Msg> pipe)
Constructors in zmq with parameters of type Msg Constructor Description Msg(Msg m)
Msg(Msg src, java.io.ByteArrayOutputStream out)
-
Uses of Msg in zmq.io
Fields in zmq.io with type parameters of type Msg Modifier and Type Field 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
Methods in zmq.io that return Msg Modifier and Type Method 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
SessionBase. pullMsg()
private Msg
StreamEngine. pullMsgFromSession()
Msg
SessionBase. readZapMsg()
Methods in zmq.io with parameters of type Msg Modifier and Type Method 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)
-
Uses of Msg in zmq.io.coder
Fields in zmq.io.coder declared as Msg Modifier and Type Field Description protected Msg
Decoder. inProgress
protected Msg
EncoderBase. inProgress
Methods in zmq.io.coder that return Msg Modifier and Type Method Description protected Msg
Decoder. allocate(int size)
Msg
Decoder. msg()
Msg
IDecoder. msg()
Methods in zmq.io.coder with parameters of type Msg Modifier and Type Method 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)
-
Uses of Msg in zmq.io.coder.raw
Fields in zmq.io.coder.raw declared as Msg Modifier and Type Field Description protected Msg
RawDecoder. inProgress
Methods in zmq.io.coder.raw that return Msg Modifier and Type Method Description Msg
RawDecoder. msg()
-
Uses of Msg in zmq.io.coder.v2
Methods in zmq.io.coder.v2 that return Msg Modifier and Type Method Description protected Msg
V2Decoder. allocate(int size)
-
Uses of Msg in zmq.io.mechanism
Methods in zmq.io.mechanism that return Msg Modifier and Type Method Description Msg
Mechanism. decode(Msg msg)
Msg
Mechanism. encode(Msg msg)
Msg
Mechanism. peerIdentity()
Methods in zmq.io.mechanism with parameters of type Msg Modifier and Type Method 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. 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 Msg Modifier and Type Method Description Msg
CurveClientMechanism. decode(Msg msg)
Msg
CurveServerMechanism. decode(Msg msg)
Msg
CurveClientMechanism. encode(Msg msg)
Msg
CurveServerMechanism. encode(Msg msg)
Methods in zmq.io.mechanism.curve with parameters of type Msg Modifier and Type Method Description Msg
CurveClientMechanism. decode(Msg msg)
Msg
CurveServerMechanism. decode(Msg msg)
Msg
CurveClientMechanism. encode(Msg msg)
Msg
CurveServerMechanism. encode(Msg msg)
int
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 Msg Modifier and Type Method Description int
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 Msg Modifier and Type Method 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)
-
Uses of Msg in zmq.msg
Methods in zmq.msg that return Msg Modifier and Type Method Description Msg
MsgAllocator. allocate(int size)
Msg
MsgAllocatorDirect. allocate(int size)
Msg
MsgAllocatorHeap. allocate(int size)
Msg
MsgAllocatorThreshold. allocate(int size)
-
Uses of Msg in zmq.pipe
Classes in zmq.pipe with type parameters of type Msg Modifier and Type Class Description (package private) class
DBuffer<T extends Msg>
class
YPipeConflate<T extends Msg>
Fields in zmq.pipe declared as Msg Modifier and Type Field Description private T
DBuffer. back
private T
DBuffer. front
Fields in zmq.pipe with type parameters of type Msg Modifier and Type Field Description private YPipeBase<Msg>
Pipe. inpipe
private YPipeBase<Msg>
Pipe. outpipe
Methods in zmq.pipe that return Msg Modifier and Type Method Description Msg
Pipe. read()
Methods in zmq.pipe with parameters of type Msg Modifier and Type Method Description private static boolean
Pipe. isDelimiter(Msg msg)
boolean
Pipe. write(Msg msg)
Method parameters in zmq.pipe with type arguments of type Msg Modifier and Type Method Description protected void
Pipe. processHiccup(YPipeBase<Msg> pipe)
Constructor parameters in zmq.pipe with type arguments of type Msg Constructor Description Pipe(ZObject parent, YPipeBase<Msg> inpipe, YPipeBase<Msg> outpipe, int inhwm, int outhwm, boolean conflate)
-
Uses of Msg in zmq.socket
Fields in zmq.socket declared as Msg Modifier and Type Field Description private Msg
Stream. prefetchedId
private Msg
Stream. prefetchedMsg
Methods in zmq.socket that return Msg Modifier and Type Method Description Msg
FQ. recv(Errno errno)
Msg
FQ. recvPipe(Errno errno, ValueReference<Pipe> pipe)
protected Msg
Pair. xrecv()
Msg
Stream. xrecv()
Methods in zmq.socket with parameters of type Msg Modifier and Type Method Description boolean
LB. sendpipe(Msg msg, Errno errno, ValueReference<Pipe> pipe)
protected boolean
Pair. xsend(Msg msg)
protected boolean
Stream. xsend(Msg msg)
-
Uses of Msg in zmq.socket.pipeline
Methods in zmq.socket.pipeline that return Msg Modifier and Type Method Description Msg
Pull. xrecv()
Methods in zmq.socket.pipeline with parameters of type Msg Modifier and Type Method Description boolean
Push. xsend(Msg msg)
-
Uses of Msg in zmq.socket.pubsub
Fields in zmq.socket.pubsub declared as Msg Modifier and Type Field Description private Msg
XSub. message
Methods in zmq.socket.pubsub that return Msg Modifier and Type Method Description protected Msg
Pub. xrecv()
protected Msg
XPub. xrecv()
protected Msg
XSub. xrecv()
Methods in zmq.socket.pubsub with parameters of type Msg Modifier and Type Method Description boolean
Mtrie. add(Msg msg, Pipe pipe)
boolean
Trie. add(Msg msg, int start, int size)
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
Mtrie. rm(Msg msg, Pipe pipe)
boolean
Trie. rm(Msg msg, int start, int size)
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
Sub. xsend(Msg msg)
protected boolean
XPub. xsend(Msg msg)
protected boolean
XSub. xsend(Msg msg)
-
Uses of Msg in zmq.socket.reqrep
Fields in zmq.socket.reqrep declared as Msg Modifier and Type Field Description private Msg
Router. prefetchedId
private Msg
Router. prefetchedMsg
Methods in zmq.socket.reqrep that return Msg Modifier and Type Method Description protected 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 Modifier and Type Method Description boolean
Req.ReqSession. pushMsg(Msg msg)
protected boolean
Dealer. sendpipe(Msg msg, ValueReference<Pipe> pipe)
protected boolean
Dealer. xsend(Msg msg)
protected boolean
Rep. xsend(Msg msg)
boolean
Req. xsend(Msg msg)
protected boolean
Router. xsend(Msg msg)
-
Uses of Msg in zmq.util
Methods in zmq.util that return Msg Modifier and Type Method Description static Msg
Wire. putUInt16(Msg msg, int value)
static Msg
Wire. putUInt32(Msg msg, int value)
Methods in zmq.util with parameters of type Msg Modifier and Type Method 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)
-