Contents

# encoding: utf-8

class ZMQ::Socket::Push

# == ZMQ::Socket::Push
#
# A socket of type ZMQ::Socket::Push is used by a pipeline node to send messages to downstream pipeline nodes. Messages are
# load-balanced to all connected downstream nodes. The ZMQ::Socket#recv function is not implemented for this socket type.
#
# When a ZMQ::Socket::Push socket enters an exceptional state due to having reached the high water mark for all downstream
# nodes, or if there are no downstream nodes at all, then any ZMQ::Socket#send operations on the socket shall block until
# the exceptional state ends or at least one downstream node becomes available for sending; messages are not discarded.
#
# Deprecated alias: ZMQ_DOWNSTREAM.
#
# === Summary of ZMQ::Socket::Push characteristics
#
# [Compatible peer sockets] ZMQ::Socket::Pull
# [Direction] Unidirectional
# [Send/receive pattern] Send only
# [Incoming routing strategy] N/A
# [Outgoing routing strategy] Load-balanced
# [ZMQ::Socket#hwm option action] Block

  TYPE_STR = "PUSH"

  def type
    ZMQ::PUSH
  end

  include ZMQ::UpstreamSocket
end

Version data entries

28 entries across 28 versions & 1 rubygems

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