require "manageiq-messaging"

ManageIQ::Messaging.logger = Logger.new(STDOUT)
ManageIQ::Messaging::Client.open(
  :host => "localhost",
  :port => 61616,
  :user => "admin",
  :password => "smartvm",
  :client_ref => "event_handler",
) do |client|
  puts "Listening for events..."

  client.subscribe_messages(
    :service => "events",
    :limit   => 10
  ) do |messages|
    puts "Received #{messages.count} events..."
    messages.each do |msg|
      puts "#{msg.message}"
      client.ack(msg.ack_ref)
    end
  end

  loop { sleep 5 }
end