Class: ZMQ::Socket::Rep
- Inherits:
-
ZMQ::Socket
- Object
- ZMQ::Socket
- ZMQ::Socket::Rep
- Defined in:
- lib/zmq/socket/rep.rb,
ext/rbczmq/socket.c
Constant Summary collapse
- TYPE_STR =
ZMQ::Socket::Rep
A socket of type ZMQ::Socket::Rep is used by a service to receive requests from and send replies to a client. This socket type allows only an alternating sequence of ZMQ::Socket#recv and subsequent ZMQ::Socket#send calls. Each request received is fair-queued from among all clients, and each reply sent is routed to the client that issued the last request. If the original requester doesn’t exist any more the reply is silently discarded.
When a ZMQ::Socket::Rep socket enters an exceptional state due to having reached the high water mark for a client, then any replies sent to the client in question shall be dropped until the exceptional state ends.
Summary of ZMQ::Socket#rep characteristics
- Compatible peer sockets
-
ZMQ::Socket::Rep
- Direction
-
Bidirectional
- Send/receive pattern
-
Receive, Send, Receive, Send, …
- Incoming routing strategy
-
Fair-queued
- Outgoing routing strategy
-
Last peer
- ZMQ::Socket#hwm option action
-
Drop
"REP"
Constants inherited from ZMQ::Socket
BOUND, CONNECTED, DISCONNECTED, PENDING, PROTO_REXP
Instance Method Summary collapse
Methods inherited from ZMQ::Socket
#affinity, #affinity=, #backlog, #backlog=, #bind, #close, #connect, #connect_all, #delay_attach_on_connect=, #disconnect, #endpoint, #endpoints, #events, #fd, handle_fsm_errors, #identity=, #ipv4only=, #ipv4only?, #last_endpoint, #linger, #linger=, #maxmsgsize, #maxmsgsize=, #monitor, #multicast_hops, #multicast_hops=, #poll, #poll_readable?, #poll_writable?, #rate, #rate=, #rcvbuf, #rcvbuf=, #rcvhwm, #rcvhwm=, #rcvmore?, #rcvtimeo, #rcvtimeo=, #readable?, #real_bind, #real_connect, #reconnect_ivl, #reconnect_ivl=, #reconnect_ivl_max, #reconnect_ivl_max=, #recovery_ivl, #recovery_ivl=, #recv, #recv_frame, #recv_frame_nonblock, #recv_message, #recv_nonblock, #router_mandatory=, #router_raw=, #send, #send_message, #sendm, #sndbuf, #sndbuf=, #sndhwm, #sndhwm=, #sndtimeo, #sndtimeo=, #state, #subscribe, #to_s, #type_str, #unbind, #unsubscribe, unsupported_api, #verbose=, #writable?, #xpub_verbose=