astor proxy

gistfile1.rb

class LibratoProxy
  def on_readable(socket, messages)
    messages.each {|msg| post_to_librato *msg.copy_out_string.split(' ')  }
  end

  def post_to_librato(channel, metric_in_json)
    metric = JSON.parse(metric_in_json)

    # call to Librato API
  end
end

ctx = EM::ZeroMQ::Context.new(1)
EM::run do
  socket = ctx.socket ZMQ::SUB, LibratoProxy.new
  socket.identity = "proxy-#{Process.pid}"
  socket.connect "tcp://127.0.0.1:8890"
  socket.subscribe 'metric'
end