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 ZMQ.Socket |
ZProxy.ProxyActor.backend |
private ZMQ.Socket |
ZProxy.ProxyActor.capture |
private ZMQ.Socket |
ZProxy.ProxyActor.frontend |
private ZMQ.Socket |
ZAuth.ZapRequest.handler |
private ZMQ.Socket |
ZMQQueue.inSocket |
private ZMQ.Socket |
ZMonitor.MonitorActor.monitor |
private ZMQ.Socket |
ZMonitor.MonitorActor.monitored |
private ZMQ.Socket |
ZMQQueue.outSocket |
private ZMQ.Socket |
ZAgent.SimpleAgent.pipe |
private ZMQ.Socket |
ZThread.ShimThread.pipe |
private ZMQ.Socket |
ZActor.Double.pipe |
private ZMQ.Socket |
ZAuth.AuthActor.replies |
private ZMQ.Socket |
ZMQ.PollItem.socket |
private ZMQ.Socket |
ZPoller.CompositePollItem.socket |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<ZMQ.Socket> |
ZContext.sockets
List of sockets managed by this ZContext
|
private BiFunction<ZMQ.Socket,java.lang.Integer,java.lang.Boolean> |
ZPoller.ComposeEventsHandler.sockets |
private java.util.List<ZMQ.Socket> |
ZActor.Double.sockets |
Modifier and Type | Method and Description |
---|---|
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.
|
ZMQ.Socket |
ZContext.createSocket(int type)
Deprecated.
|
ZMQ.Socket |
ZContext.createSocket(SocketType type)
Creates a new managed socket within this ZContext instance.
|
static ZMQ.Socket |
ZThread.fork(ZContext ctx,
ZThread.IAttachedRunnable runnable,
java.lang.Object... args) |
ZMQ.Socket |
ZContext.fork(ZThread.IAttachedRunnable runnable,
java.lang.Object... args)
Create an attached thread, An attached thread gets a ctx and a PAIR pipe back to its
parent.
|
ZMQ.Socket |
ZMQ.PollItem.getSocket() |
ZMQ.Socket |
ZMQ.Poller.getSocket(int index)
Get the socket associated with an index.
|
ZMQ.Socket |
ZStar.pipe() |
ZMQ.Socket |
ZAgent.pipe()
Returns the socket used for communication.
|
ZMQ.Socket |
ZAgent.SimpleAgent.pipe() |
ZMQ.Socket |
ZPoller.ItemHolder.socket() |
ZMQ.Socket |
ZPoller.ZPollItem.socket() |
ZMQ.Socket |
ZPoller.CompositePollItem.socket() |
ZMQ.Socket |
ZMQ.Context.socket(int type)
Deprecated.
|
ZMQ.Socket |
ZMQ.Context.socket(SocketType type)
Creates a ØMQ socket within the specified context and return an opaque handle to the newly created socket.
|
Modifier and Type | Method and Description |
---|---|
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) |
java.util.List<ZMQ.Socket> |
ZContext.getSockets()
Return a copy of the list of currently open sockets.
|
Modifier and Type | Method and Description |
---|---|
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 |
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) |
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) |
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.SimpleActor.closed(ZMQ.Socket socket) |
void |
ZActor.Duo.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.SimpleProxy.configure(ZMQ.Socket pipe,
ZMsg cfg,
ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture,
java.lang.Object... args) |
boolean |
ZProxy.Proxy.configure(ZMQ.Socket socket,
ZProxy.Plug place,
java.lang.Object... args)
Configures the given socket.
|
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. |
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) |
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 |
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) |
void |
ZContext.destroySocket(ZMQ.Socket s)
Deprecated.
Not to be used any more.
ZMQ.Socket handle
the close itself. It also override linger settings. |
static boolean |
ZMQ.device(int type,
ZMQ.Socket frontend,
ZMQ.Socket backend)
Deprecated.
|
boolean |
ZPoller.error(ZMQ.Socket socket) |
boolean |
ZPoller.EventsHandler.events(ZMQ.Socket socket,
int events)
Called when the poller intercepts events.
|
boolean |
ZPoller.ComposeEventsHandler.events(ZMQ.Socket socket,
int events) |
boolean |
ZPoller.CompositePollItem.events(ZMQ.Socket socket,
int events) |
boolean |
ZActor.Double.events(ZMQ.Socket socket,
int events) |
boolean |
ZActor.Actor.finished(ZMQ.Socket pipe)
Called when the stage is finished.
|
boolean |
ZActor.SimpleActor.finished(ZMQ.Socket pipe) |
boolean |
ZActor.Duo.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.ZPump.flow(ZProxy.Plug splug,
ZMQ.Socket source,
ZMQ.Socket capture,
ZProxy.Plug dplug,
ZMQ.Socket destination) |
boolean |
ZProxy.ZmqPump.flow(ZProxy.Plug splug,
ZMQ.Socket source,
ZMQ.Socket capture,
ZProxy.Plug dplug,
ZMQ.Socket destination) |
boolean |
ZStar.Fortune.interview(ZMQ.Socket mic)
The show is over.
|
boolean |
ZActor.ActorFortune.interview(ZMQ.Socket mic) |
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 |
ZProxy.ProxyActor.looped(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) |
long |
ZProxy.ProxyActor.looping(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) |
boolean |
ZPoller.pollerr(ZMQ.Socket socket) |
boolean |
ZPoller.pollin(ZMQ.Socket socket) |
boolean |
ZPoller.pollout(ZMQ.Socket socket) |
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 |
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.SimpleActor.premiere(ZMQ.Socket pipe) |
java.lang.String |
ZActor.Duo.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.
|
java.lang.String |
ZActor.ActorFortune.premiere(ZMQ.Socket mic,
java.lang.Object... args) |
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.
|
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.
|
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.
|
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
|
private boolean |
ZProxy.ProxyActor.restart(ZMQ.Socket pipe,
boolean hot) |
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) |
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 |
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.send(ZMQ.Socket socket,
int flags)
Internal method to call org.zeromq.Socket send() method.
|
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 |
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) |
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) |
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) |
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) |
private boolean |
ZMonitor.MonitorActor.start(ZPoller poller,
ZMQ.Socket pipe) |
void |
ZMQ.Poller.unregister(ZMQ.Socket socket)
Unregister a Socket for polling on the specified events.
|
boolean |
ZPoller.writable(ZMQ.Socket socket) |
Modifier and Type | Method and Description |
---|---|
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.
|
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) |
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) |
Constructor and Description |
---|
Double(ZContext ctx,
ZMQ.Socket pipe,
ZActor.Actor actor,
java.lang.Object... args) |
MonitorActor(ZMQ.Socket socket) |
PollItem(ZMQ.Socket socket,
int ops) |
ShimThread(ZContext ctx,
ZThread.IAttachedRunnable runnable,
java.lang.Object[] args,
ZMQ.Socket pipe) |
SimpleAgent(ZMQ.Socket pipe,
java.lang.String lock)
Creates a new simple agent.
|
ZapRequest(ZMQ.Socket handler,
ZMsg request) |
ZMonitor(ZContext ctx,
ZMQ.Socket socket)
Creates a monitoring actor for the given socket.
|
ZMQQueue(ZMQ.Context context,
ZMQ.Socket inSocket,
ZMQ.Socket outSocket)
Class constructor.
|
ZPollItem(ZMQ.Socket socket,
ZPoller.EventsHandler handler,
int ops) |
Constructor and Description |
---|
ComposeEventsHandler(BiFunction<ZMQ.Socket,java.lang.Integer,java.lang.Boolean> sockets,
BiFunction<java.nio.channels.SelectableChannel,java.lang.Integer,java.lang.Boolean> channels) |
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,
ZStar.Fortune fortune,
BiFunction<ZMQ.Socket,java.lang.String,ZAgent> agent,
java.lang.String motdelafin,
java.lang.Object... bags)
Creates a new ZStar.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object[] |
ZPicture.recvBinaryPicture(ZMQ.Socket socket,
java.lang.String picture)
Receive a binary encoded 'picture' message from the socket (or actor).
|
java.lang.Object[] |
ZPicture.recvPicture(ZMQ.Socket socket,
java.lang.String picture)
Receive a 'picture' message to the socket (or actor).
|
boolean |
ZPicture.sendBinaryPicture(ZMQ.Socket socket,
java.lang.String picture,
java.lang.Object... args) |
boolean |
ZPicture.sendPicture(ZMQ.Socket socket,
java.lang.String picture,
java.lang.Object... args)
Queues a 'picture' message to the socket (or actor), so it can be sent.
|