Uses of Class
org.zeromq.ZMQ.Socket
Packages that use ZMQ.Socket
Package
Description
Provides high-level bindings for ØMQ.
Provides utility classes for ØMQ zproto.
-
Uses of ZMQ.Socket in org.zeromq
Fields in org.zeromq declared as ZMQ.SocketModifier and TypeFieldDescriptionprivate 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.SocketModifier and TypeFieldDescriptionprivate final List
<ZMQ.Socket> ZActor.Double.sockets
private final Set
<ZMQ.Socket> ZContext.sockets
List of sockets managed by this ZContextprivate final BiFunction
<ZMQ.Socket, Integer, Boolean> ZPoller.ComposeEventsHandler.sockets
Methods in org.zeromq that return ZMQ.SocketModifier and TypeMethodDescriptionZProxy.Proxy.create
(ZContext ctx, ZProxy.Plug place, Object... args) Creates and initializes (bind, options ...) the socket for the given plug in the proxy.ZContext.createSocket
(int type) Deprecated.ZContext.createSocket
(SocketType type) Creates a new managed socket within this ZContext instance.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.Poller.getSocket
(int index) Get the socket associated with an index.final ZMQ.Socket
ZMQ.PollItem.getSocket()
ZAgent.pipe()
Returns the socket used for communication.ZAgent.SimpleAgent.pipe()
ZStar.pipe()
ZMQ.Context.socket
(int type) Deprecated.ZMQ.Context.socket
(SocketType type) Creates a ØMQ socket within the specified context and return an opaque handle to the newly created socket.ZPoller.CompositePollItem.socket()
ZPoller.ItemHolder.socket()
ZPoller.ZPollItem.socket()
Methods in org.zeromq that return types with arguments of type ZMQ.SocketModifier and TypeMethodDescriptionZActor.Actor.createSockets
(ZContext ctx, Object... args) Creates and initializes sockets for the double.ZActor.Duo.createSockets
(ZContext ctx, Object... args) ZActor.SimpleActor.createSockets
(ZContext ctx, Object... args) ZAuth.AuthActor.createSockets
(ZContext ctx, Object... args) ZMonitor.MonitorActor.createSockets
(ZContext ctx, Object... args) ZProxy.ProxyActor.createSockets
(ZContext ctx, Object... args) ZContext.getSockets()
Return a copy of the list of currently open sockets.Methods in org.zeromq with parameters of type ZMQ.SocketModifier and TypeMethodDescriptionprivate 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) 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) 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.ItemCreator.create
(ZMQ.Socket socket, ZPoller.EventsHandler handler, int events) Creates a new holder for a poll item.ZPoller.SimpleCreator.create
(ZMQ.Socket socket, ZPoller.EventsHandler handler, int events) 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.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) Destroys managed socket within this context and remove from sockets liststatic 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) 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.ZActor.ActorFortune.premiere
(ZMQ.Socket mic, Object... args) ZActor.Duo.premiere
(ZMQ.Socket pipe) ZActor.SimpleActor.premiere
(ZMQ.Socket pipe) ZAuth.AuthActor.premiere
(ZMQ.Socket pipe) ZMonitor.MonitorActor.premiere
(ZMQ.Socket pipe) ZProxy.ProxyActor.premiere
(ZMQ.Socket pipe) 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) private byte[]
ZFrame.recv
(ZMQ.Socket socket, int flags) Internal method to call recv on the 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 handlerstatic 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 handlerprivate 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 socketboolean
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.SocketModifier and TypeMethodDescriptionfinal 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.SocketModifierConstructorDescriptionDouble
(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.SocketModifierConstructorDescriptionComposeEventsHandler
(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.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.SocketModifier and TypeMethodDescriptionObject[]
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.
ZContext.createSocket(SocketType)