Zue

ZeroMQ Queue. Rhymes with "queue".

Loosely based on the ZeroMQ Freelance protocol. Read the rationale for the Freelance protocol.

Servers

handler = lambda do |job|
  puts job.ccf
  job.messages.each { |msg| puts msg }
  puts
end

server = Zue::Server.new 'tcp://127.0.0.1:5555', handler
server.perform

Clients

client = Zue::Client.new
client.add_server 'tcp://127.0.0.1:5555'
#client.add_server 'tcp://127.0.0.1:5556'

client.deliver "abc"