Sha256: 20af25dad735a5f9a0d7b09efd44d9c9071155547c79568c8e1f86cfa381b8ec

Contents?: true

Size: 1.3 KB

Versions: 28

Compression:

Stored size: 1.3 KB

Contents

# encoding: utf-8

class ZMQ::Socket::Dealer

# == ZMQ::Socket::Dealer
#
# A socket of type ZMQ::Socket::Dealer is an advanced pattern used for extending request/reply sockets. Each message sent is
# load-balanced among all connected peers, and each message received is fair-queued from all connected peers.
#
# Previously this socket was called ZMQ_XREQ and that name remains available for backwards compatibility.
#
# When a ZMQ::Socket::Dealer socket enters an exceptional state due to having reached the high water mark for all peers, or if
# there are no peers at all, then any ZMQ::Socket#send operations on the socket shall block until the exceptional state ends
# or at least one peer becomes available for sending; messages are not discarded.
#
# When a ZMQ::Socket::Dealer socket is connected to a ZMQ::Socket::Rep socket each message sent must consist of an empty message part,
# the delimiter, followed by one or more body parts.
#
# === Summary of ZMQ::Socket::Dealer characteristics
#
# [Compatible peer sockets] ZMQ::Socket::Router, ZMQ::Socket::Request, ZMQ::Socket::Reply
# [Direction] Bidirectional
# [Send/receive pattern] Unrestricted
# [Outgoing routing strategy] Load-balanced
# [Incoming routing strategy] Fair-queued
# [ZMQ_HWM option action] Block

  TYPE_STR = "DEALER"

  def type
    ZMQ::DEALER
  end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version Path
rbczmq-1.7.9 lib/zmq/socket/dealer.rb
rbczmq-1.7.8 lib/zmq/socket/dealer.rb
rbczmq-1.7.7 lib/zmq/socket/dealer.rb
rbczmq-1.7.6 lib/zmq/socket/dealer.rb
rbczmq-1.7.5 lib/zmq/socket/dealer.rb
rbczmq-1.7.4 lib/zmq/socket/dealer.rb
rbczmq-1.7.3 lib/zmq/socket/dealer.rb
rbczmq-1.7.2 lib/zmq/socket/dealer.rb
rbczmq-1.7.1 lib/zmq/socket/dealer.rb
rbczmq-1.7.0 lib/zmq/socket/dealer.rb
rbczmq-1.6.4 lib/zmq/socket/dealer.rb
rbczmq-1.6.2 lib/zmq/socket/dealer.rb
rbczmq-1.6 lib/zmq/socket/dealer.rb
rbczmq-1.5 lib/zmq/socket/dealer.rb
rbczmq-1.4 lib/zmq/socket/dealer.rb
rbczmq-1.3 lib/zmq/socket/dealer.rb
rbczmq-1.2 lib/zmq/socket/dealer.rb
rbczmq-1.1 lib/zmq/socket/dealer.rb
rbczmq-1.0 lib/zmq/socket/dealer.rb
rbczmq-0.9 lib/zmq/socket/dealer.rb