Uses of Class
org.zeromq.ZMQ.Socket

Packages that use ZMQ.Socket

Package	Description
org.zeromq

Uses of ZMQ.Socket in org.zeromq

Methods in org.zeromq that return ZMQ.Socket

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	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	ZMQ.Context.socket(int type) Create a new Socket within this context.

Methods in org.zeromq that return types with arguments of type ZMQ.Socket

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()

Methods in org.zeromq with parameters of type ZMQ.Socket

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(ZMQ.Socket pipe, ZPoller poller) Called when the current double has been destroyed.
boolean	ZActor.SimpleActor.destroyed(ZMQ.Socket pipe, ZPoller poller)
boolean	ZActor.Duo.destroyed(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)

Method parameters in org.zeromq with type arguments of type ZMQ.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)

Constructors in org.zeromq with parameters of type ZMQ.Socket

Constructor and Description
ZAgent.SimpleAgent(ZMQ.Socket pipe, String lock) Creates a new simple agent.
ZMQ.PollItem(ZMQ.Socket socket, int ops)
ZMQQueue(ZMQ.Context context, ZMQ.Socket inSocket, ZMQ.Socket outSocket) Class constructor.
ZPoller.ZPollItem(ZMQ.Socket socket, ZPoller.EventsHandler handler, int ops)