Package | Description |
---|---|
org.zeromq |
Provides high-level bindings for ØMQ.
|
org.zeromq.proto |
Provides utility classes for ØMQ zproto.
|
Modifier and Type | Field and Description |
---|---|
private ZMsg |
ZProxy.ProxyActor.State.hot |
Modifier and Type | Method and 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 list
|
ZMsg |
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 DataInputStream
|
private ZMsg |
ZAuth.ZapReply.msg() |
static ZMsg |
ZMsg.newStringMsg(java.lang.String... strings)
Create a new ZMsg from one or more Strings
|
ZMsg |
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.SimpleAgent.recv() |
ZMsg |
ZStar.recv() |
ZMsg |
ZAgent.recv(boolean wait)
Receives a control message sent from the Plateau in the Corbeille.
|
ZMsg |
ZAgent.SimpleAgent.recv(boolean wait) |
ZMsg |
ZStar.recv(boolean wait) |
ZMsg |
ZAgent.recv(int timeout)
Receives a control message sent from the Plateau in the Corbeille.
|
ZMsg |
ZAgent.SimpleAgent.recv(int timeout) |
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.Transformer.transform(ZMsg msg,
ZProxy.Plug src,
ZProxy.Plug dst)
Transforms a ZMsg into another ZMsg.
|
ZMsg |
ZProxy.ZPump.Identity.transform(ZMsg msg,
ZProxy.Plug src,
ZProxy.Plug dst) |
ZMsg |
ZMsg.wrap(ZFrame frame)
Push frame plus empty frame to front of message, before 1st frame.
|
Modifier and Type | Method and 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 |
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) |
ZMsg |
ZProxy.configure(ZMsg msg)
Configures the proxy.
|
boolean |
ZAuth.Auth.configure(ZMsg msg,
boolean verbose)
Configures with ad-hoc message.
|
boolean |
ZAuth.SimplePlainAuth.configure(ZMsg msg,
boolean verbose) |
boolean |
ZAuth.SimpleCurveAuth.configure(ZMsg configuration,
boolean verbose) |
boolean |
ZAuth.SimpleNullAuth.configure(ZMsg configuration,
boolean verbose) |
private static ZAuth.ZapReply |
ZAuth.ZapReply.received(ZMsg msg) |
java.lang.String |
ZProxy.restart(ZMsg hot)
Restarts the proxy.
|
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) |
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.SimpleAgent.send(ZMsg message) |
boolean |
ZStar.send(ZMsg message) |
boolean |
ZAgent.send(ZMsg msg,
boolean destroy)
Sends a control message from Corbeille side to the Plateau side.
|
boolean |
ZAgent.SimpleAgent.send(ZMsg msg,
boolean destroy) |
boolean |
ZStar.send(ZMsg msg,
boolean destroy) |
boolean |
ZSocket.sendMessage(ZMsg message) |
ZMsg |
ZProxy.ZPump.Transformer.transform(ZMsg msg,
ZProxy.Plug src,
ZProxy.Plug dst)
Transforms a ZMsg into another ZMsg.
|
ZMsg |
ZProxy.ZPump.Identity.transform(ZMsg msg,
ZProxy.Plug src,
ZProxy.Plug dst) |
Modifier and Type | Method and 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 handler
|
static 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 handler
|
Constructor and Description |
---|
ZapRequest(ZMQ.Socket handler,
ZMsg request) |
ZEvent(ZMsg msg) |
Modifier and Type | Method and 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.
|