gistfile1

require 'qmf'
require 'thread'

$queue = Queue.new

class MyHandler < Qmf::ConsoleHandler
  def agent_added(agent)
    $queue << agent
  end
end

$connection = Qmf::Connection.new(Qmf::ConnectionSettings.new) unless $connection
$console = Qmf::Console.new(MyHandler.new) unless $console
$broker = $console.add_connection($connection) unless $broker