ZMQ recv demo

zmq-recv.rb

#!/usr/bin/env ruby

require "rubygems"
require "zmq"
require 'json'

context = ZMQ::Context.new(1)
inbound = context.socket(ZMQ::UPSTREAM)
inbound.bind("tcp://127.0.0.1:9000")

Signal.trap('INT') {
  puts "SIGINT"
}

loop do
  puts "sleeping"
  begin
    text = inbound.recv
  rescue ZMQ::Error
    redo
  end

  obj = JSON.parse(text)
  p obj
end