Package | Description |
---|---|
org.zeromq |
Modifier and Type | Method and Description |
---|---|
ZMQ.Socket |
ZProxy.Proxy.create(ZContext ctx,
ZProxy.Plug place,
Object[] args)
Creates and initializes (bind, options ...) the socket for the given plug in the proxy.
|
ZMQ.Socket |
ZContext.createSocket(int type)
Creates a new managed socket within this ZContext instance.
|
static ZMQ.Socket |
ZThread.fork(ZContext ctx,
ZThread.IAttachedRunnable runnable,
Object... args) |
ZMQ.Socket |
ZMQ.PollItem.getSocket() |
ZMQ.Socket |
ZMQ.Poller.getSocket(int index)
Get the socket associated with an index.
|
ZMQ.Socket |
ZAgent.pipe()
Returns the socket used for communication.
|
ZMQ.Socket |
ZAgent.SimpleAgent.pipe() |
ZMQ.Socket |
ZStar.pipe() |
ZMQ.Socket |
ZPoller.ItemHolder.socket() |
ZMQ.Socket |
ZPoller.ZPollItem.socket() |
ZMQ.Socket |
ZMQ.Context.socket(int type)
Create a new Socket within this context.
|
Modifier and Type | Method and Description |
---|---|
List<ZMQ.Socket> |
ZActor.Actor.createSockets(ZContext ctx,
Object[] args)
Creates and initializes sockets for the double.
|
List<ZMQ.Socket> |
ZActor.SimpleActor.createSockets(ZContext ctx,
Object[] args) |
List<ZMQ.Socket> |
ZActor.Duo.createSockets(ZContext ctx,
Object[] args) |
List<ZMQ.Socket> |
ZContext.getSockets() |
Modifier and Type | Method and Description |
---|---|
protected ZAgent |
ZStar.agent(ZMQ.Socket phone,
String secret)
Creates a new agent for the star.
|
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,
Object[] bags)
Called when the show is about to start.
|
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) |
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) |
void |
ZProxy.Proxy.configure(ZMQ.Socket socket,
ZProxy.Plug place,
Object[] args)
Configures the given socket.
|
ZStar.Star |
ZStar.Fortune.create(ZContext ctx,
ZMQ.Socket mic,
Selector sel,
int count,
ZStar.Star previous,
Object[] args)
Creates a star.
|
static ZAgent |
ZAgent.Creator.create(ZMQ.Socket pipe,
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.
|
boolean |
ZProxy.Proxy.custom(ZMQ.Socket pipe,
String cmd,
ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture,
Object[] args)
Handles a custom command not recognized by the proxy.
|
boolean |
ZProxy.Proxy.SimpleProxy.custom(ZMQ.Socket pipe,
String cmd,
ZMQ.Socket frontend,
ZMQ.Socket backend,
ZMQ.Socket capture,
Object[] args) |
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)
Destroys managed socket within this context
and remove from sockets list
|
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 |
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 |
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.SimpleActor.looped(ZMQ.Socket pipe,
ZPoller poller) |
boolean |
ZActor.Duo.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) |
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.
|
String |
ZActor.SimpleActor.premiere(ZMQ.Socket pipe) |
String |
ZActor.Duo.premiere(ZMQ.Socket pipe) |
String |
ZStar.Fortune.premiere(ZMQ.Socket mic,
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.
|
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,
int flag)
Receives message from socket, returns ZMsg object or null if the
recv was interrupted.
|
int |
ZMQ.Poller.register(ZMQ.Socket socket)
Register a Socket for polling on all events.
|
boolean |
ZPoller.register(ZMQ.Socket socket,
int 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,
ZPoller.EventsHandler handler) |
boolean |
ZPoller.register(ZMQ.Socket socket,
ZPoller.EventsHandler handler,
int events)
Register a Socket for polling on specified events.
|
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) |
void |
ZThread.IAttachedRunnable.run(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.
|
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 |
ZActor.Actor.start(ZMQ.Socket pipe,
List<ZMQ.Socket> sockets,
ZPoller poller)
Called when the double is started, before the first loop.
|
void |
ZActor.SimpleActor.start(ZMQ.Socket pipe,
List<ZMQ.Socket> sockets,
ZPoller poller) |
void |
ZActor.Duo.start(ZMQ.Socket pipe,
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) |
Modifier and Type | Method and Description |
---|---|
void |
ZActor.Actor.start(ZMQ.Socket pipe,
List<ZMQ.Socket> sockets,
ZPoller poller)
Called when the double is started, before the first loop.
|
void |
ZActor.SimpleActor.start(ZMQ.Socket pipe,
List<ZMQ.Socket> sockets,
ZPoller poller) |
void |
ZActor.Duo.start(ZMQ.Socket pipe,
List<ZMQ.Socket> sockets,
ZPoller poller) |
Constructor and Description |
---|
PollItem(ZMQ.Socket socket,
int ops) |
SimpleAgent(ZMQ.Socket pipe,
String lock)
Creates a new simple agent.
|
ZMQQueue(ZMQ.Context context,
ZMQ.Socket inSocket,
ZMQ.Socket outSocket)
Class constructor.
|
ZPollItem(ZMQ.Socket socket,
ZPoller.EventsHandler handler,
int ops) |
Copyright © 2019. All rights reserved.