Uses of Class
org.zeromq.ZMQ.Socket

Packages that use ZMQ.Socket

Package	Description
org.zeromq	Provides high-level bindings for ØMQ.
org.zeromq.proto	Provides utility classes for ØMQ zproto.

Uses of ZMQ.Socket in org.zeromq

Fields in org.zeromq declared as ZMQ.Socket

Modifier and Type	Field	Description
private ZMQ.Socket	ZProxy.ProxyActor.backend
private ZMQ.Socket	ZProxy.ProxyActor.capture
private ZMQ.Socket	ZProxy.ProxyActor.frontend
private final ZMQ.Socket	ZAuth.ZapRequest.handler
private final ZMQ.Socket	ZMQQueue.inSocket
private ZMQ.Socket	ZMonitor.MonitorActor.monitor
private final ZMQ.Socket	ZMonitor.MonitorActor.monitored
private final ZMQ.Socket	ZMQQueue.outSocket
private final ZMQ.Socket	ZActor.Double.pipe
private final ZMQ.Socket	ZAgent.SimpleAgent.pipe
private ZMQ.Socket	ZThread.ShimThread.pipe
private ZMQ.Socket	ZAuth.AuthActor.replies
private final ZMQ.Socket	ZMQ.PollItem.socket
private final ZMQ.Socket	ZPoller.CompositePollItem.socket

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

Modifier and Type	Field	Description
private final List<ZMQ.Socket>	ZActor.Double.sockets
private final Set<ZMQ.Socket>	ZContext.sockets	List of sockets managed by this ZContext
private final BiFunction<ZMQ.Socket, Integer, Boolean>	ZPoller.ComposeEventsHandler.sockets

Methods in org.zeromq that return ZMQ.Socket

Modifier and Type	Method	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)	Deprecated. use ZContext.createSocket(SocketType)
ZMQ.Socket	ZContext.createSocket(SocketType type)	Creates a new managed socket within this ZContext instance.
ZMQ.Socket	ZContext.fork(ZThread.IAttachedRunnable runnable, Object... args)	Create an attached thread, An attached thread gets a ctx and a PAIR pipe back to its parent.
static ZMQ.Socket	ZThread.fork(ZContext ctx, ZThread.IAttachedRunnable runnable, Object... args)
ZMQ.Socket	ZMQ.Poller.getSocket(int index)	Get the socket associated with an index.
final ZMQ.Socket	ZMQ.PollItem.getSocket()
ZMQ.Socket	ZAgent.pipe()	Returns the socket used for communication.
ZMQ.Socket	ZAgent.SimpleAgent.pipe()
ZMQ.Socket	ZStar.pipe()
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.
ZMQ.Socket	ZPoller.CompositePollItem.socket()
ZMQ.Socket	ZPoller.ItemHolder.socket()
ZMQ.Socket	ZPoller.ZPollItem.socket()

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

Modifier and Type	Method	Description
List<ZMQ.Socket>	ZActor.Actor.createSockets(ZContext ctx, Object... args)	Creates and initializes sockets for the double.
List<ZMQ.Socket>	ZActor.Duo.createSockets(ZContext ctx, Object... args)
List<ZMQ.Socket>	ZActor.SimpleActor.createSockets(ZContext ctx, Object... args)
List<ZMQ.Socket>	ZAuth.AuthActor.createSockets(ZContext ctx, Object... args)
List<ZMQ.Socket>	ZMonitor.MonitorActor.createSockets(ZContext ctx, Object... args)
List<ZMQ.Socket>	ZProxy.ProxyActor.createSockets(ZContext ctx, Object... args)
List<ZMQ.Socket>	ZContext.getSockets()	Return a copy of the list of currently open sockets.

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

Modifier and Type	Method	Description
private boolean	ZMonitor.MonitorActor.addEvents(ZMQ.Socket pipe)
protected ZAgent	ZStar.agent(ZMQ.Socket phone, String secret)	Deprecated.
void	ZCert.apply(ZMQ.Socket socket)
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.Duo.backstage(ZMQ.Socket pipe, ZPoller poller, int events)
boolean	ZActor.SimpleActor.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)
void	ZStar.Entourage.breakaleg(ZContext ctx, ZStar.Fortune fortune, ZMQ.Socket phone, 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.Duo.closed(ZMQ.Socket socket)
void	ZActor.SimpleActor.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, Object... args)	Configures the proxy with a custom message.
boolean	ZProxy.Proxy.configure(ZMQ.Socket socket, ZProxy.Plug place, Object... args)	Configures the given socket.
boolean	ZProxy.Proxy.SimpleProxy.configure(ZMQ.Socket pipe, ZMsg cfg, ZMQ.Socket frontend, ZMQ.Socket backend, ZMQ.Socket capture, Object... args)
ZStar.Star	ZActor.ActorFortune.create(ZContext ctx, ZMQ.Socket pipe, int count, ZStar.Star previous, Object... args)
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.
ZPoller.ItemHolder	ZPoller.SimpleCreator.create(ZMQ.Socket socket, ZPoller.EventsHandler handler, int events)
ZStar.Star	ZStar.Fortune.create(ZContext ctx, ZMQ.Socket mic, int count, ZStar.Star previous, Object... args)	Creates a star.
default ZStar.Star	ZStar.Fortune.create(ZContext ctx, ZMQ.Socket mic, Selector sel, int count, ZStar.Star previous, Object... args)	Deprecated. use ZStar.Fortune.create(ZContext, Socket, int, Star, Object...) instead.
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.Duo.destroyed(ZContext ctx, ZMQ.Socket pipe, ZPoller poller)
boolean	ZActor.SimpleActor.destroyed(ZContext ctx, ZMQ.Socket pipe, ZPoller poller)
boolean	ZProxy.ProxyActor.destroyed(ZContext ctx, ZMQ.Socket pipe, ZPoller poller)
void	ZContext.destroySocket(ZMQ.Socket s)	Deprecated. Not to be used any more.
static boolean	ZMQ.device(int type, ZMQ.Socket frontend, ZMQ.Socket backend)	Deprecated.
boolean	ZPoller.error(ZMQ.Socket socket)
boolean	ZActor.Double.events(ZMQ.Socket socket, int events)
boolean	ZPoller.ComposeEventsHandler.events(ZMQ.Socket socket, int events)
boolean	ZPoller.CompositePollItem.events(ZMQ.Socket socket, int events)
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.Duo.finished(ZMQ.Socket pipe)
boolean	ZActor.SimpleActor.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.ZmqPump.flow(ZProxy.Plug splug, ZMQ.Socket source, ZMQ.Socket capture, ZProxy.Plug dplug, ZMQ.Socket destination)
boolean	ZProxy.ZPump.flow(ZProxy.Plug splug, ZMQ.Socket source, ZMQ.Socket capture, ZProxy.Plug dplug, ZMQ.Socket destination)
boolean	ZActor.ActorFortune.interview(ZMQ.Socket mic)
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.Duo.looped(ZMQ.Socket pipe, ZPoller poller)
boolean	ZActor.SimpleActor.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.Duo.looping(ZMQ.Socket pipe, ZPoller poller)
long	ZActor.SimpleActor.looping(ZMQ.Socket pipe, ZPoller poller)
long	ZProxy.ProxyActor.looping(ZMQ.Socket pipe, ZPoller poller)
boolean	ZPoller.pollerr(ZMQ.Socket socket)
boolean	ZPoller.pollin(ZMQ.Socket socket)
boolean	ZPoller.pollout(ZMQ.Socket socket)
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.ActorFortune.premiere(ZMQ.Socket mic, Object... args)
String	ZActor.Duo.premiere(ZMQ.Socket pipe)
String	ZActor.SimpleActor.premiere(ZMQ.Socket pipe)
String	ZAuth.AuthActor.premiere(ZMQ.Socket pipe)
String	ZMonitor.MonitorActor.premiere(ZMQ.Socket pipe)
String	ZProxy.ProxyActor.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.
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.
int	ZMQ.Poller.register(ZMQ.Socket socket, int events)	Register a Socket for polling on the specified events.
final boolean	ZPoller.register(ZMQ.Socket socket, int events)
final boolean	ZPoller.register(ZMQ.Socket socket, ZPoller.EventsHandler handler)
final boolean	ZPoller.register(ZMQ.Socket socket, ZPoller.EventsHandler handler, int events)	Register a Socket for polling on specified events.
final boolean	ZPoller.register(ZMQ.Socket socket, BiFunction<ZMQ.Socket, Integer, Boolean> 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, String statusText, ZMQ.Socket replies)	Send a zap reply to the handler socket
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)
private boolean	ZProxy.ProxyActor.restart(ZMQ.Socket pipe, boolean hot)
void	ZStar.Plateau.run(Object[] train, ZContext chef, ZMQ.Socket mic)
void	ZThread.IAttachedRunnable.run(Object[] args, ZContext ctx, ZMQ.Socket pipe)
boolean	ZFrame.send(ZMQ.Socket socket, int flags)	Internal method to call org.zeromq.Socket send() method.
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.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, Object... bags)
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.Duo.stage(ZMQ.Socket socket, ZMQ.Socket pipe, ZPoller poller, int events)
boolean	ZActor.SimpleActor.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, List<ZMQ.Socket> sockets, ZPoller poller)	Called when the double is started, before the first loop.
void	ZActor.Duo.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
void	ZActor.SimpleActor.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
void	ZAuth.AuthActor.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
void	ZMonitor.MonitorActor.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
private boolean	ZMonitor.MonitorActor.start(ZPoller poller, ZMQ.Socket pipe)
void	ZProxy.ProxyActor.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	Description
final boolean	ZPoller.register(ZMQ.Socket socket, BiFunction<ZMQ.Socket, Integer, Boolean> handler, int events)	Register a Socket for polling on specified 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.Duo.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
void	ZActor.SimpleActor.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
void	ZAuth.AuthActor.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
void	ZMonitor.MonitorActor.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)
void	ZProxy.ProxyActor.start(ZMQ.Socket pipe, List<ZMQ.Socket> sockets, ZPoller poller)

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

Modifier	Constructor	Description
	Double(ZContext ctx, ZMQ.Socket pipe, ZActor.Actor actor, Object... args)
	MonitorActor(ZMQ.Socket socket)
	PollItem(ZMQ.Socket socket, int ops)
protected	ShimThread(ZContext ctx, ZThread.IAttachedRunnable runnable, Object[] args, ZMQ.Socket pipe)
	SimpleAgent(ZMQ.Socket pipe, String lock)	Creates a new simple agent.
private	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 parameters in org.zeromq with type arguments of type ZMQ.Socket

Modifier	Constructor	Description
	ComposeEventsHandler(BiFunction<ZMQ.Socket, Integer, Boolean> sockets, BiFunction<SelectableChannel, Integer, Boolean> channels)
	ZStar(ZContext context, ZAgent.SelectorCreator selector, ZStar.Fortune fortune, BiFunction<ZMQ.Socket, String, ZAgent> agent, String motdelafin, Object... bags)	Deprecated. use ZStar(ZContext, Fortune, BiFunction, String, Object...) instead.
	ZStar(ZContext context, ZStar.Fortune fortune, BiFunction<ZMQ.Socket, String, ZAgent> agent, String motdelafin, Object... bags)	Creates a new ZStar.

Uses of ZMQ.Socket in org.zeromq.proto

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

Modifier and Type	Method	Description
Object[]	ZPicture.recvBinaryPicture(ZMQ.Socket socket, String picture)	Receive a binary encoded 'picture' message from the socket (or actor).
Object[]	ZPicture.recvPicture(ZMQ.Socket socket, String picture)	Receive a 'picture' message to the socket (or actor).
boolean	ZPicture.sendBinaryPicture(ZMQ.Socket socket, String picture, Object... args)
boolean	ZPicture.sendPicture(ZMQ.Socket socket, String picture, Object... args)	Queues a 'picture' message to the socket (or actor), so it can be sent.