Celluloid 0MQ router

zmq-test-router.rb

require 'celluloid/zmq'

Celluloid::ZMQ.init

class Server
  include Celluloid::ZMQ

  def initialize(address)
    @socket = RouterSocket.new
    @socket.set ::ZMQ::SNDHWM, 0
    @socket.set ::ZMQ::RCVHWM, 0

    begin
      @socket.bind(address)
    rescue IOError
      @socket.close
      raise
    end
  end

  def run
    loop do
      async.handle_message @socket.read_multipart
    end
  end

  def handle_message(parts)
    puts "PARTS: #{parts.inspect}"
    @socket.send(parts[0], parts[1], "Received #{parts[2]}")
  end
end

addr = 'tcp://127.0.0.1:3435'
server = Server.new(addr)
server.run