Uses of Class
org.zeromq.ZMsg
-
Packages that use ZMsg Package Description org.zeromq Provides high-level bindings for ØMQ.org.zeromq.proto Provides utility classes for ØMQ zproto. -
-
Uses of ZMsg in org.zeromq
Fields in org.zeromq declared as ZMsg Modifier and Type Field Description private ZMsg
ZProxy.ProxyActor.State. hot
Methods in org.zeromq that return ZMsg Modifier and Type Method Description ZMsg
ZMsg. addFirst(byte[] data)
ZMsg
ZMsg. addFirst(java.lang.String stringValue)
ZMsg
ZMsg. addLast(byte[] data)
ZMsg
ZMsg. addLast(java.lang.String stringValue)
ZMsg
ZMsg. addString(java.lang.String str)
Add a String as a new ZFrame to the end of listZMsg
ZMsg. append(byte[] data)
Adds bytes as a new frame in the message.ZMsg
ZMsg. append(java.lang.String stringValue)
Adds a string as a new frame in the message.ZMsg
ZMsg. append(ZMsg msg)
ZMsg
ZProxy. command(ZProxy.Command command, ZMsg msg, boolean sync)
Sends a command message to the proxy actor.ZMsg
ZProxy. configure(ZMsg msg)
Configures the proxy.ZMsg
ZMsg. dump()
ZMsg
ZMsg. dump(java.lang.Appendable out)
Dump the message in human readable format.ZMsg
ZMsg. duplicate()
Creates copy of this ZMsg.static ZMsg
ZMsg. load(java.io.DataInputStream file)
Load / append a ZMsg from an open DataInputStreamprivate ZMsg
ZAuth.ZapReply. msg()
static ZMsg
ZMsg. newStringMsg(java.lang.String... strings)
Create a new ZMsg from one or more StringsZMsg
ZMsg. push(byte[] data)
ZMsg
ZMsg. push(java.lang.String str)
ZMsg
ZAgent. recv()
Receives a control message sent from the Plateau in the Corbeille.ZMsg
ZAgent. recv(boolean wait)
Receives a control message sent from the Plateau in the Corbeille.ZMsg
ZAgent. recv(int timeout)
Receives a control message sent from the Plateau in the Corbeille.ZMsg
ZAgent.SimpleAgent. recv()
ZMsg
ZAgent.SimpleAgent. recv(boolean wait)
ZMsg
ZAgent.SimpleAgent. recv(int timeout)
ZMsg
ZStar. recv()
ZMsg
ZStar. recv(boolean wait)
ZMsg
ZStar. recv(int timeout)
static ZMsg
ZMsg. recvMsg(ZMQ.Socket socket)
Receives message from socket, returns ZMsg object or null if the recv was interrupted.static ZMsg
ZMsg. recvMsg(ZMQ.Socket socket, boolean wait)
Receives message from socket, returns ZMsg object or null if the recv was interrupted.static ZMsg
ZMsg. recvMsg(ZMQ.Socket socket, int flag)
Receives message from socket, returns ZMsg object or null if the recv was interrupted.private ZMsg
ZProxy.ProxyActor. status()
ZMsg
ZProxy.ZPump.Identity. transform(ZMsg msg, ZProxy.Plug src, ZProxy.Plug dst)
ZMsg
ZProxy.ZPump.Transformer. transform(ZMsg msg, ZProxy.Plug src, ZProxy.Plug dst)
Transforms a ZMsg into another ZMsg.ZMsg
ZMsg. wrap(ZFrame frame)
Push frame plus empty frame to front of message, before 1st frame.Methods in org.zeromq with parameters of type ZMsg Modifier and Type Method Description ZMsg
ZMsg. append(ZMsg msg)
ZMsg
ZProxy. command(ZProxy.Command command, ZMsg msg, boolean sync)
Sends a command message to the proxy actor.boolean
ZAuth.Auth. configure(ZMsg msg, boolean verbose)
Configures with ad-hoc message.boolean
ZAuth.SimpleCurveAuth. configure(ZMsg configuration, boolean verbose)
boolean
ZAuth.SimpleNullAuth. configure(ZMsg configuration, boolean verbose)
boolean
ZAuth.SimplePlainAuth. configure(ZMsg msg, boolean verbose)
ZMsg
ZProxy. configure(ZMsg msg)
Configures the proxy.boolean
ZProxy.Proxy. configure(ZMQ.Socket pipe, ZMsg cfg, ZMQ.Socket frontend, ZMQ.Socket backend, ZMQ.Socket capture, java.lang.Object... args)
Configures the proxy with a custom message.boolean
ZProxy.Proxy.SimpleProxy. configure(ZMQ.Socket pipe, ZMsg cfg, ZMQ.Socket frontend, ZMQ.Socket backend, ZMQ.Socket capture, java.lang.Object... args)
private static ZAuth.ZapReply
ZAuth.ZapReply. received(ZMsg msg)
boolean
ZProxy.Proxy. restart(ZMsg cfg, ZMQ.Socket socket, ZProxy.Plug place, java.lang.Object... args)
Performs a hot restart of the given socket.boolean
ZProxy.Proxy.SimpleProxy. restart(ZMsg cfg, ZMQ.Socket socket, ZProxy.Plug place, java.lang.Object... args)
java.lang.String
ZProxy. restart(ZMsg hot)
Restarts the proxy.static boolean
ZMsg. save(ZMsg msg, java.io.DataOutputStream file)
Save message to an open data output stream.boolean
ZAgent. send(ZMsg message)
Sends a control message from the Corbeille to the Plateau.boolean
ZAgent. send(ZMsg msg, boolean destroy)
Sends a control message from Corbeille side to the Plateau side.boolean
ZAgent.SimpleAgent. send(ZMsg message)
boolean
ZAgent.SimpleAgent. send(ZMsg msg, boolean destroy)
boolean
ZStar. send(ZMsg message)
boolean
ZStar. send(ZMsg msg, boolean destroy)
boolean
ZSocket. sendMessage(ZMsg message)
ZMsg
ZProxy.ZPump.Identity. transform(ZMsg msg, ZProxy.Plug src, ZProxy.Plug dst)
ZMsg
ZProxy.ZPump.Transformer. transform(ZMsg msg, ZProxy.Plug src, ZProxy.Plug dst)
Transforms a ZMsg into another ZMsg.Method parameters in org.zeromq with type arguments of type ZMsg Modifier and Type Method Description static void
ZMsg. recvMsg(ZMQ.Socket socket, int flags, Consumer<ZMsg> handler)
This API is in DRAFT state and is subject to change at ANY time until declared stable handle incoming message with a handlerstatic void
ZMsg. recvMsg(ZMQ.Socket socket, int flags, Consumer<ZMsg> handler, Consumer<ZMQException> exceptionHandler)
This API is in DRAFT state and is subject to change at ANY time until declared stable handle incoming message with a handlerConstructors in org.zeromq with parameters of type ZMsg Constructor Description ZapRequest(ZMQ.Socket handler, ZMsg request)
ZEvent(ZMsg msg)
-
Uses of ZMsg in org.zeromq.proto
Methods in org.zeromq.proto that return ZMsg Modifier and Type Method Description ZMsg
ZPicture. msgBinaryPicture(java.lang.String picture, java.lang.Object... args)
Creates a binary encoded 'picture' message to the socket (or actor), so it can be sent.
-