Package | Description |
---|---|
org.zeromq |
Provides high-level bindings for ØMQ.
|
Modifier and Type | Field and Description |
---|---|
private ZPoller |
ZActor.Double.poller |
Modifier and Type | Method and Description |
---|---|
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.SimpleActor.backstage(ZMQ.Socket pipe,
ZPoller poller,
int events) |
boolean |
ZActor.Duo.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) |
private boolean |
ZMonitor.MonitorActor.close(ZPoller poller,
ZMQ.Socket pipe) |
boolean |
ZActor.Actor.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller)
Called when the current double has been destroyed.
|
boolean |
ZActor.SimpleActor.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
boolean |
ZActor.Duo.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
boolean |
ZProxy.ProxyActor.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
boolean |
ZActor.Actor.looped(ZMQ.Socket pipe,
ZPoller poller)
Called at the end of each loop.
|
boolean |
ZActor.SimpleActor.looped(ZMQ.Socket pipe,
ZPoller poller) |
boolean |
ZActor.Duo.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.SimpleActor.looping(ZMQ.Socket pipe,
ZPoller poller) |
long |
ZActor.Duo.looping(ZMQ.Socket pipe,
ZPoller poller) |
long |
ZProxy.ProxyActor.looping(ZMQ.Socket pipe,
ZPoller poller) |
private boolean |
ZProxy.ProxyActor.pause(ZPoller poller,
boolean pause) |
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.SimpleActor.stage(ZMQ.Socket socket,
ZMQ.Socket pipe,
ZPoller poller,
int events) |
boolean |
ZActor.Duo.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.SimpleActor.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
void |
ZActor.Duo.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) |
void |
ZProxy.ProxyActor.start(ZMQ.Socket pipe,
java.util.List<ZMQ.Socket> sockets,
ZPoller poller) |
private boolean |
ZProxy.ProxyActor.start(ZPoller poller) |
private boolean |
ZMonitor.MonitorActor.start(ZPoller poller,
ZMQ.Socket pipe) |
Constructor and Description |
---|
ZPoller(ZPoller.ItemCreator creator,
ZPoller poller)
Creates a new poller based on the current one.
|
ZPoller(ZPoller poller)
Creates a new poller based on the current one.
|