private boolean |
ZMonitor.MonitorActor.addEvents(ZMQ.Socket pipe) |
|
protected ZAgent |
ZStar.agent(ZMQ.Socket phone,
java.lang.String secret) |
Deprecated.
|
void |
ZCert.apply(ZMQ.Socket socket) |
|
boolean |
ZActor.Actor.backstage(ZMQ.Socket pipe,
ZPoller poller,
int events) |
Called when the actor received a control message from its pipe during a loop.
|
boolean |
ZActor.Duo.backstage(ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
boolean |
ZActor.SimpleActor.backstage(ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
boolean |
ZAuth.AuthActor.backstage(ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
boolean |
ZMonitor.MonitorActor.backstage(ZMQ.Socket pipe,
ZPoller poller,
int evts) |
|
boolean |
ZProxy.ProxyActor.backstage(ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
void |
ZStar.Entourage.breakaleg(ZContext ctx,
ZStar.Fortune fortune,
ZMQ.Socket phone,
java.lang.Object... bags) |
Called when the show is about to start.
|
private boolean |
ZMonitor.MonitorActor.close(ZPoller poller,
ZMQ.Socket pipe) |
|
void |
ZActor.Actor.closed(ZMQ.Socket socket) |
Called when a created socket has been closed.
|
void |
ZActor.Duo.closed(ZMQ.Socket socket) |
|
void |
ZActor.SimpleActor.closed(ZMQ.Socket socket) |
|
(package private) void |
ZContext.closeSocket(ZMQ.Socket s) |
Close managed socket within this context and remove from sockets list.
|
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.configure(ZMQ.Socket socket,
ZProxy.Plug place,
java.lang.Object... args) |
Configures the given socket.
|
boolean |
ZProxy.Proxy.SimpleProxy.configure(ZMQ.Socket pipe,
ZMsg cfg,
ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture,
java.lang.Object... args) |
|
ZStar.Star |
ZActor.ActorFortune.create(ZContext ctx,
ZMQ.Socket pipe,
int count,
ZStar.Star previous,
java.lang.Object... args) |
|
static ZAgent |
ZAgent.Creator.create(ZMQ.Socket pipe,
java.lang.String lock) |
|
protected ZPoller.ItemHolder |
ZPoller.create(ZMQ.Socket socket,
ZPoller.EventsHandler handler,
int events) |
|
ZPoller.ItemHolder |
ZPoller.ItemCreator.create(ZMQ.Socket socket,
ZPoller.EventsHandler handler,
int events) |
Creates a new holder for a poll item.
|
ZPoller.ItemHolder |
ZPoller.SimpleCreator.create(ZMQ.Socket socket,
ZPoller.EventsHandler handler,
int events) |
|
ZStar.Star |
ZStar.Fortune.create(ZContext ctx,
ZMQ.Socket mic,
int count,
ZStar.Star previous,
java.lang.Object... args) |
Creates a star.
|
default ZStar.Star |
ZStar.Fortune.create(ZContext ctx,
ZMQ.Socket mic,
java.nio.channels.Selector sel,
int count,
ZStar.Star previous,
java.lang.Object... args) |
Deprecated.
|
boolean |
ZProxy.Proxy.custom(ZMQ.Socket pipe,
java.lang.String cmd,
ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture,
java.lang.Object... args) |
Handles a custom command not recognized by the proxy.
|
boolean |
ZProxy.Proxy.SimpleProxy.custom(ZMQ.Socket pipe,
java.lang.String cmd,
ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture,
java.lang.Object... args) |
|
boolean |
ZActor.Actor.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
Called when the current double has been destroyed.
|
boolean |
ZActor.Duo.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
|
boolean |
ZActor.SimpleActor.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
|
boolean |
ZProxy.ProxyActor.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
|
void |
ZContext.destroySocket(ZMQ.Socket s) |
Deprecated.
|
static boolean |
ZMQ.device(int type,
ZMQ.Socket frontend,
ZMQ.Socket backend) |
Deprecated.
|
boolean |
ZPoller.error(ZMQ.Socket socket) |
|
boolean |
ZActor.Double.events(ZMQ.Socket socket,
int events) |
|
boolean |
ZPoller.ComposeEventsHandler.events(ZMQ.Socket socket,
int events) |
|
boolean |
ZPoller.CompositePollItem.events(ZMQ.Socket socket,
int events) |
|
boolean |
ZPoller.EventsHandler.events(ZMQ.Socket socket,
int events) |
Called when the poller intercepts events.
|
boolean |
ZActor.Actor.finished(ZMQ.Socket pipe) |
Called when the stage is finished.
|
boolean |
ZActor.Duo.finished(ZMQ.Socket pipe) |
|
boolean |
ZActor.SimpleActor.finished(ZMQ.Socket pipe) |
|
boolean |
ZProxy.Pump.flow(ZProxy.Plug src,
ZMQ.Socket source,
ZMQ.Socket capture,
ZProxy.Plug dst,
ZMQ.Socket destination) |
Transfers a message from one source to one destination, with an optional capture.
|
boolean |
ZProxy.ZmqPump.flow(ZProxy.Plug splug,
ZMQ.Socket source,
ZMQ.Socket capture,
ZProxy.Plug dplug,
ZMQ.Socket destination) |
|
boolean |
ZProxy.ZPump.flow(ZProxy.Plug splug,
ZMQ.Socket source,
ZMQ.Socket capture,
ZProxy.Plug dplug,
ZMQ.Socket destination) |
|
boolean |
ZActor.ActorFortune.interview(ZMQ.Socket mic) |
|
boolean |
ZStar.Fortune.interview(ZMQ.Socket mic) |
The show is over.
|
boolean |
ZPoller.isError(ZMQ.Socket socket) |
Tells if a socket is in error from this poller.
|
boolean |
ZPoller.isReadable(ZMQ.Socket socket) |
Tells if a socket is readable from this poller.
|
boolean |
ZPoller.isWritable(ZMQ.Socket socket) |
Tells if a socket is writable from this poller.
|
boolean |
ZActor.Actor.looped(ZMQ.Socket pipe,
ZPoller poller) |
Called at the end of each loop.
|
boolean |
ZActor.Duo.looped(ZMQ.Socket pipe,
ZPoller poller) |
|
boolean |
ZActor.SimpleActor.looped(ZMQ.Socket pipe,
ZPoller poller) |
|
boolean |
ZProxy.ProxyActor.looped(ZMQ.Socket pipe,
ZPoller poller) |
|
long |
ZActor.Actor.looping(ZMQ.Socket pipe,
ZPoller poller) |
Called every time just before a loop starts.
|
long |
ZActor.Duo.looping(ZMQ.Socket pipe,
ZPoller poller) |
|
long |
ZActor.SimpleActor.looping(ZMQ.Socket pipe,
ZPoller poller) |
|
long |
ZProxy.ProxyActor.looping(ZMQ.Socket pipe,
ZPoller poller) |
|
boolean |
ZPoller.pollerr(ZMQ.Socket socket) |
|
boolean |
ZPoller.pollin(ZMQ.Socket socket) |
|
boolean |
ZPoller.pollout(ZMQ.Socket socket) |
|
java.lang.String |
ZActor.Actor.premiere(ZMQ.Socket pipe) |
This is the grand premiere!
Called before the creation of the first double and the sockets
2nd in the order call of the global acting.
|
java.lang.String |
ZActor.ActorFortune.premiere(ZMQ.Socket mic,
java.lang.Object... args) |
|
java.lang.String |
ZActor.Duo.premiere(ZMQ.Socket pipe) |
|
java.lang.String |
ZActor.SimpleActor.premiere(ZMQ.Socket pipe) |
|
java.lang.String |
ZAuth.AuthActor.premiere(ZMQ.Socket pipe) |
|
java.lang.String |
ZMonitor.MonitorActor.premiere(ZMQ.Socket pipe) |
|
java.lang.String |
ZProxy.ProxyActor.premiere(ZMQ.Socket pipe) |
|
java.lang.String |
ZStar.Fortune.premiere(ZMQ.Socket mic,
java.lang.Object... args) |
This is the grand premiere!
Called when the star enters the plateau.
|
static boolean |
ZMQ.proxy(ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture) |
Starts the built-in 0MQ proxy in the current application thread.
|
static boolean |
ZMQ.proxy(ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture,
ZMQ.Socket control) |
|
boolean |
ZPoller.readable(ZMQ.Socket socket) |
|
static ZMQ.Event |
ZMQ.Event.recv(ZMQ.Socket socket) |
Receive an event from a monitor socket.
|
static ZMQ.Event |
ZMQ.Event.recv(ZMQ.Socket socket,
int flags) |
Receive an event from a monitor socket.
|
static ZFrame |
ZFrame.recvFrame(ZMQ.Socket socket) |
Receives single frame from socket, returns the received frame object, or null if the recv
was interrupted.
|
static ZFrame |
ZFrame.recvFrame(ZMQ.Socket socket,
int flags) |
Receive a new frame off the socket, Returns newly-allocated frame, or
null if there was no input waiting, or if the read was interrupted.
|
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.
|
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
|
private static ZAuth.ZapRequest |
ZAuth.ZapRequest.recvRequest(ZMQ.Socket handler,
boolean wait) |
|
int |
ZMQ.Poller.register(ZMQ.Socket socket) |
Register a Socket for polling on all events.
|
int |
ZMQ.Poller.register(ZMQ.Socket socket,
int events) |
Register a Socket for polling on the specified events.
|
boolean |
ZPoller.register(ZMQ.Socket socket,
int events) |
|
boolean |
ZPoller.register(ZMQ.Socket socket,
ZPoller.EventsHandler handler) |
|
boolean |
ZPoller.register(ZMQ.Socket socket,
ZPoller.EventsHandler handler,
int events) |
Register a Socket for polling on specified events.
|
boolean |
ZPoller.register(ZMQ.Socket socket,
BiFunction<ZMQ.Socket,java.lang.Integer,java.lang.Boolean> handler,
int events) |
Register a Socket for polling on specified events.
|
private boolean |
ZMonitor.MonitorActor.removeEvents(ZMQ.Socket pipe) |
|
private void |
ZAuth.ZapRequest.reply(int statusCode,
java.lang.String statusText,
ZMQ.Socket replies) |
Send a zap reply to the handler socket
|
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) |
|
private boolean |
ZProxy.ProxyActor.restart(ZMQ.Socket pipe,
boolean hot) |
|
void |
ZStar.Plateau.run(java.lang.Object[] train,
ZContext chef,
ZMQ.Socket mic) |
|
void |
ZThread.IAttachedRunnable.run(java.lang.Object[] args,
ZContext ctx,
ZMQ.Socket pipe) |
|
boolean |
ZFrame.send(ZMQ.Socket socket,
int flags) |
Internal method to call org.zeromq.Socket send() method.
|
boolean |
ZMsg.send(ZMQ.Socket socket) |
Send message to 0MQ socket.
|
boolean |
ZMsg.send(ZMQ.Socket socket,
boolean destroy) |
Send message to 0MQ socket, destroys contents after sending if destroy param is set to true.
|
boolean |
ZFrame.sendAndDestroy(ZMQ.Socket socket) |
Sends frame to socket if it contains data.
|
boolean |
ZFrame.sendAndDestroy(ZMQ.Socket socket,
int flags) |
Sends frame to socket if it contains data.
|
boolean |
ZFrame.sendAndKeep(ZMQ.Socket socket) |
Sends frame to socket if it contains any data.
|
boolean |
ZFrame.sendAndKeep(ZMQ.Socket socket,
int flags) |
Sends frame to socket if it contains any data.
|
private void |
ZStar.Plateau.showMustGoOn(ZContext chef,
ZStar.Set set,
ZMQ.Socket phone,
ZStar.Fortune fortune,
java.lang.Object... bags) |
|
boolean |
ZActor.Actor.stage(ZMQ.Socket socket,
ZMQ.Socket pipe,
ZPoller poller,
int events) |
The actor received a message from the created sockets during a loop.
|
boolean |
ZActor.Duo.stage(ZMQ.Socket socket,
ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
boolean |
ZActor.SimpleActor.stage(ZMQ.Socket socket,
ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
boolean |
ZAuth.AuthActor.stage(ZMQ.Socket socket,
ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
boolean |
ZMonitor.MonitorActor.stage(ZMQ.Socket socket,
ZMQ.Socket pipe,
ZPoller poller,
int evts) |
|
boolean |
ZProxy.ProxyActor.stage(ZMQ.Socket socket,
ZMQ.Socket pipe,
ZPoller poller,
int events) |
|
void |
ZActor.Actor.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
Called when the double is started, before the first loop.
|
void |
ZActor.Duo.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
|
void |
ZActor.SimpleActor.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
|
void |
ZAuth.AuthActor.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
|
void |
ZMonitor.MonitorActor.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
|
private boolean |
ZMonitor.MonitorActor.start(ZPoller poller,
ZMQ.Socket pipe) |
|
void |
ZProxy.ProxyActor.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
|
void |
ZMQ.Poller.unregister(ZMQ.Socket socket) |
Unregister a Socket for polling on the specified events.
|
boolean |
ZPoller.writable(ZMQ.Socket socket) |
|