Uses of Class
zmq.Msg

Packages that use Msg

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

Uses of Msg in org.zeromq

Constructors in org.zeromq with parameters of type Msg

Modifier	Constructor	Description
protected	ZFrame(Msg msg)	Class Constructor Uses internal Msg class to access routingId

Uses of Msg in zmq

Subclasses of Msg in zmq

Modifier and Type	Class	Description
static final class	Msg.Builder

Fields in zmq declared as Msg

Modifier and Type	Field	Description
Msg	Options.disconnectMsg
Msg	Options.helloMsg
Msg	Options.hiccupMsg

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(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(ByteBuffer src)
Msg	Msg.put(ByteBuffer src, int off, int len)
Msg	Msg.Builder.putShortString(String data)
Msg	Msg.putShortString(String data)	Puts a string into the message, prefixed with its length.
final Msg	SocketBase.recv(int flags)
final Msg	SocketBase.recv(int flags, 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()

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)
String	ZMQ.getMessageGroup(Msg msg)
static String	ZMQ.getMessageMetadata(Msg msg, String property)
static int	ZMQ.getMessageOption(Msg msg, int option)
int	ZMQ.getMessageRoutingId(Msg msg)
static int	ZMQ.msgSize(Msg msg)
final boolean	SocketBase.send(Msg msg, int flags)
final boolean	SocketBase.send(Msg msg, int flags, 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, String group)
boolean	ZMQ.setMessageRoutingId(Msg msg, int routingId)
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 final void	ZObject.sendHiccup(Pipe destination, YPipeBase<Msg> pipe)

Constructors in zmq with parameters of type Msg

Modifier	Constructor	Description
	Msg(Msg m)
private	Msg(Msg src, ByteArrayOutputStream out)

Uses of Msg in zmq.io

Classes in zmq.io that implement interfaces with type arguments of type Msg

Modifier and Type	Class	Description
private final class	StreamEngine.ProducePongMessage

Fields in zmq.io with type parameters of type Msg

Modifier and Type	Field	Description
private final Function<Msg,Boolean>	StreamEngine.decodeAndPush
private final Supplier<Msg>	StreamEngine.nextHandshakeCommand
private final Supplier<Msg>	StreamEngine.nextIdentity
private Supplier<Msg>	StreamEngine.nextMsg
private final Function<Msg,Boolean>	StreamEngine.processHandshakeCommand
private final Function<Msg,Boolean>	StreamEngine.processIdentity
private Function<Msg,Boolean>	StreamEngine.processMsg
private final Supplier<Msg>	StreamEngine.producePingMessage
private final Supplier<Msg>	StreamEngine.pullAndEncode
private final Supplier<Msg>	StreamEngine.pullMsgFromSession
private final Function<Msg,Boolean>	StreamEngine.pushMsgToSession
private final Function<Msg,Boolean>	StreamEngine.pushOneThenDecodeAndPush
private final Function<Msg,Boolean>	StreamEngine.pushRawMsgToSession
private final Function<Msg,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	HelloMsgSession.pullMsg()
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)
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 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
final 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, 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)
final Msg	Mechanism.peerIdentity()

Methods in zmq.io.mechanism with parameters of type Msg

Modifier and Type	Method	Description
protected final void	Mechanism.addProperty(Msg msg, String name, byte[] value)
protected final void	Mechanism.addProperty(Msg msg, String name, String value)
protected boolean	Mechanism.compare(Msg msg, 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 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 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 Msg	Pipe.disconnectMsg
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)
void	Pipe.sendHiccupMsg(Msg hiccupMsg)
void	Pipe.setDisconnectMsg(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

Modifier	Constructor	Description
private	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	Channel.xrecv()
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	Channel.xsend(Msg msg)
protected boolean	Pair.xsend(Msg msg)
protected boolean	Stream.xsend(Msg msg)

Uses of Msg in zmq.socket.clientserver

Methods in zmq.socket.clientserver that return Msg

Modifier and Type	Method	Description
protected Msg	Client.xrecv()
protected Msg	Server.xrecv()

Methods in zmq.socket.clientserver with parameters of type Msg

Modifier and Type	Method	Description
protected boolean	Client.xsend(Msg msg)
protected boolean	Server.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.radiodish

Fields in zmq.socket.radiodish declared as Msg

Modifier and Type	Field	Description
private Msg	Radio.RadioSession.pending
private Msg	Dish.pendingMsg

Methods in zmq.socket.radiodish that return Msg

Modifier and Type	Method	Description
protected Msg	Dish.DishSession.pullMsg()
protected Msg	Radio.RadioSession.pullMsg()
protected Msg	Dish.xrecv()
protected Msg	Radio.xrecv()
private Msg	Dish.xxrecv()

Methods in zmq.socket.radiodish with parameters of type Msg

Modifier and Type	Method	Description
boolean	Dish.DishSession.pushMsg(Msg msg)
boolean	Radio.RadioSession.pushMsg(Msg msg)
protected boolean	Dish.xsend(Msg msg)
protected boolean	Radio.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 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

Modifier and Type	Method	Description
boolean	Req.ReqSession.pushMsg(Msg msg)
protected final 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.socket.scattergather

Methods in zmq.socket.scattergather that return Msg

Modifier and Type	Method	Description
protected Msg	Gather.xrecv()

Methods in zmq.socket.scattergather with parameters of type Msg

Modifier and Type	Method	Description
protected boolean	Scatter.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)