ZMQ Push/Pull Exploration

pull.rb

require 'rubygems'
require 'zmq'

context = ZMQ::Context.new

# Start listening
pull = context.socket(ZMQ::PULL)
pull.bind("tcp://127.0.0.1:5555")

# Get updates, exit on ^C
begin
  while line = pull.recv
    puts line
  end
rescue Exception => e
end

pull.close

push.rb

require 'rubygems'
require 'zmq'

context = ZMQ::Context.new

push = context.socket(ZMQ::PUSH)
push.connect("tcp://127.0.0.1:5555")

# Send block of messages, or default to one at a time
count = ARGV[0].to_i || 1

# Broadcast 20 updates, sleeping between
20.times do |i|
  count.times do |j|
    push.send("Update #{i}.#{j}")
  end
  sleep(1)
end

push.send("END")

push.close