sensu amqp test

sensu_amqp.rb

#!/opt/sensu/embedded/bin/ruby
require 'pp'
require 'amqp'
require 'eventmachine'

EventMachine.run do
  connection = AMQP.connect(
    :host => 'foobar.example.com',
    :port => 5672,
    :ssl => true,
    :vhost => 'sensu',
    :user => 'user',
    :password => 'password')

  channel = AMQP::Channel.new(connection)
  puts "Connected"

  ex = channel.topic('metrics')
  channel.queue('metrics').bind(ex, :exclusive => true).subscribe do |h,p|
    puts h
    puts p
  end
end