Package | Description |
---|---|
org.zeromq |
Modifier and Type | Method and Description |
---|---|
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.duplicate()
Creates copy of this ZMsg.
|
static ZMsg |
ZMsg.load(DataInputStream file)
Load / append a ZMsg from an open DataInputStream
|
static ZMsg |
ZMsg.newStringMsg(String... strings)
Create a new ZMsg from one or more Strings
|
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) |
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,
int flag)
Receives message from socket, returns ZMsg object or null if the
recv was interrupted.
|
ZMsg |
ZProxy.ZPump.Transformer.transform(ZMsg msg,
ZProxy.Plug src,
ZProxy.Plug dst)
Transforms a ZMsg into another ZMsg.
|
Modifier and Type | Method and Description |
---|---|
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,
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,
Object[] args) |
ZMsg |
ZProxy.configure(ZMsg msg)
Configures the proxy.
|
String |
ZProxy.restart(ZMsg hot)
Restarts the proxy.
|
boolean |
ZProxy.Proxy.restart(ZMsg cfg,
ZMQ.Socket socket,
ZProxy.Plug place,
Object[] args)
Performs a hot restart of the given socket.
|
boolean |
ZProxy.Proxy.SimpleProxy.restart(ZMsg cfg,
ZMQ.Socket socket,
ZProxy.Plug place,
Object[] args) |
static boolean |
ZMsg.save(ZMsg msg,
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) |
ZMsg |
ZProxy.ZPump.Transformer.transform(ZMsg msg,
ZProxy.Plug src,
ZProxy.Plug dst)
Transforms a ZMsg into another ZMsg.
|
Copyright © 2016. All rights reserved.