Package | Description |
---|---|
org.zeromq |
Provides high-level bindings for ØMQ.
|
Modifier and Type | Field and Description |
---|---|
private ZContext |
ZStar.context |
private ZContext |
ZActor.Double.context |
private ZContext |
ZThread.ShimThread.ctx |
private ZContext |
ZMQ.Socket.zctx |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<ZContext> |
ZContext.shadows
List of ZContext in the shadows
|
Modifier and Type | Method and Description |
---|---|
ZContext |
ZContext.shadow()
Creates new shadow context.
|
static ZContext |
ZContext.shadow(ZContext ctx)
Deprecated.
use the instance method directly
|
Modifier and Type | Method and Description |
---|---|
void |
ZStar.Entourage.breakaleg(ZContext ctx,
ZStar.Fortune fortune,
ZMQ.Socket phone,
java.lang.Object... bags)
Called when the show is about to start.
|
ZStar.Star |
ZStar.Fortune.create(ZContext ctx,
ZMQ.Socket mic,
int count,
ZStar.Star previous,
java.lang.Object... args)
Creates a star.
|
ZStar.Star |
ZActor.ActorFortune.create(ZContext ctx,
ZMQ.Socket pipe,
int count,
ZStar.Star previous,
java.lang.Object... args) |
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.
use
#create(ZContext, Socket, int, Star, Object...) instead. |
ZMQ.Socket |
ZProxy.Proxy.create(ZContext ctx,
ZProxy.Plug place,
java.lang.Object... args)
Creates and initializes (bind, options ...) the socket for the given plug in the proxy.
|
private ZAgent |
ZAuth.AuthActor.createAgent(ZContext ctx) |
java.util.List<ZMQ.Socket> |
ZAuth.AuthActor.createSockets(ZContext ctx,
java.lang.Object... args) |
java.util.List<ZMQ.Socket> |
ZMonitor.MonitorActor.createSockets(ZContext ctx,
java.lang.Object... args) |
java.util.List<ZMQ.Socket> |
ZProxy.ProxyActor.createSockets(ZContext ctx,
java.lang.Object... args) |
java.util.List<ZMQ.Socket> |
ZActor.Actor.createSockets(ZContext ctx,
java.lang.Object... args)
Creates and initializes sockets for the double.
|
java.util.List<ZMQ.Socket> |
ZActor.SimpleActor.createSockets(ZContext ctx,
java.lang.Object... args) |
java.util.List<ZMQ.Socket> |
ZActor.Duo.createSockets(ZContext ctx,
java.lang.Object... args) |
boolean |
ZProxy.ProxyActor.destroyed(ZContext ctx,
ZMQ.Socket pipe,
ZPoller poller) |
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) |
static ZMQ.Socket |
ZThread.fork(ZContext ctx,
ZThread.IAttachedRunnable runnable,
java.lang.Object... args) |
static ZProxy |
ZProxy.newProxy(ZContext ctx,
java.lang.String name,
ZAgent.SelectorCreator selector,
ZProxy.Proxy sockets,
java.lang.String motdelafin,
java.lang.Object... args)
Deprecated.
|
static ZProxy |
ZProxy.newProxy(ZContext ctx,
java.lang.String name,
ZProxy.Proxy sockets,
java.lang.String motdelafin,
java.lang.Object... args)
Creates a new low-level proxy for better performances.
|
static ZProxy |
ZProxy.newZProxy(ZContext ctx,
java.lang.String name,
ZAgent.SelectorCreator selector,
ZProxy.Proxy sockets,
java.lang.String motdelafin,
java.lang.Object... args)
Deprecated.
|
static ZProxy |
ZProxy.newZProxy(ZContext ctx,
java.lang.String name,
ZProxy.Proxy sockets,
java.lang.String motdelafin,
java.lang.Object... args)
Creates a new proxy in a ZeroMQ way.
|
void |
ZStar.TimeTaker.party(ZContext ctx)
Called when the show is finished but no cleaning is still done.
|
void |
ZActor.ActorFortune.party(ZContext ctx) |
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) |
static ZContext |
ZContext.shadow(ZContext ctx)
Deprecated.
use the instance method directly
|
private void |
ZStar.Plateau.showMustGoOn(ZContext chef,
ZStar.Set set,
ZMQ.Socket phone,
ZStar.Fortune fortune,
java.lang.Object... bags) |
Constructor and Description |
---|
Double(ZContext ctx,
ZMQ.Socket pipe,
ZActor.Actor actor,
java.lang.Object... args) |
ShimThread(ZContext ctx,
ZThread.IAttachedRunnable runnable,
java.lang.Object[] args,
ZMQ.Socket pipe) |
Socket(ZContext context,
SocketType type)
Class constructor.
|
Socket(ZMQ.Context context,
ZContext zctx,
int type) |
ZActor(ZContext context,
ZActor.Actor actor,
java.lang.String motdelafin,
java.lang.Object... args)
Creates a new ZActor.
|
ZActor(ZContext context,
ZAgent.SelectorCreator selector,
ZActor.Actor actor,
java.lang.String motdelafin,
java.lang.Object... args)
Deprecated.
|
ZAuth(ZContext ctx)
Install authentication for the specified context.
|
ZAuth(ZContext ctx,
java.lang.String actorName) |
ZAuth(ZContext ctx,
java.lang.String actorName,
java.util.Map<java.lang.String,ZAuth.Auth> auths) |
ZAuth(ZContext ctx,
ZCertStore.Fingerprinter fingerprinter) |
ZContext(ZContext parent,
int ioThreads) |
ZLoop(ZContext ctx) |
ZMonitor(ZContext ctx,
ZMQ.Socket socket)
Creates a monitoring actor for the given socket.
|
ZPoller(ZContext context)
Creates a new poller attached to a given context that will provide
selector for operational polling.
|
ZPoller(ZPoller.ItemCreator creator,
ZContext context)
Creates a new poller attached to a given context that will provide
selector for operational polling.
|
ZPoller(ZPoller.ItemCreator creator,
ZContext context,
java.nio.channels.Selector selector)
Creates a new poller.
|
ZProxy(ZContext ctx,
java.lang.String name,
ZAgent.SelectorCreator selector,
ZProxy.Proxy sockets,
ZProxy.Pump pump,
java.lang.String motdelafin,
java.lang.Object... args)
Deprecated.
|
ZProxy(ZContext ctx,
java.lang.String name,
ZProxy.Proxy sockets,
ZProxy.Pump pump,
java.lang.String motdelafin,
java.lang.Object... args)
Creates a new named proxy.
|
ZStar(ZContext context,
ZAgent.SelectorCreator selector,
ZStar.Fortune fortune,
BiFunction<ZMQ.Socket,java.lang.String,ZAgent> agent,
java.lang.String motdelafin,
java.lang.Object... bags)
Deprecated.
|
ZStar(ZContext context,
ZAgent.SelectorCreator selector,
ZStar.Fortune fortune,
java.lang.String motdelafin,
java.lang.Object... bags)
Deprecated.
use
ZStar(ZContext, Fortune, String, Object...) instead. |
ZStar(ZContext context,
ZStar.Fortune fortune,
BiFunction<ZMQ.Socket,java.lang.String,ZAgent> agent,
java.lang.String motdelafin,
java.lang.Object... bags)
Creates a new ZStar.
|
ZStar(ZContext context,
ZStar.Fortune fortune,
java.lang.String motdelafin,
java.lang.Object... bags)
Creates a new ZStar.
|