def initialize(args={})
host = args.include?(:host) ? args[:host] : "localhost"
port = args.include?(:port) ? args[:port] : 5672
url = "#{host}:#{port}"
opts = {"reconnect"=>"true"}
@connection = Cqpid::Connection.new(url, opts)
@connection.open
@session = Qmf2::ConsoleSession.new(@connection)
@session.open
@session.set_agent_filter("[and, [eq, _vendor, [quote, 'redhat.com']], [eq, _product, [quote, 'imagefactory']]]")
if args.include?(:logger)
@logger = args[:logger]
else
@logger = Logger.new(STDOUT)
@logger.level = Logger::ERROR
@logger.datetime_format = "%Y-%m-%d %H:%M:%S"
end
@handler = args.include?(:handler)? args[:handler]: BaseHandler.new(@logger)
super(@session)
end