module Apollo::Helper::Amqp

Public Class Methods

connect(conn, opts={}) click to toggle source
# File lib/apollo_crawler/helper/amqp_helper.rb, line 29
def self.connect(conn, opts={})
        res = nil

        if(opts[:verbose])
                puts "AMQP Connecting - #{conn.inspect}"
        end

        res = Bunny.new(:host => conn['host'], :user => conn['username'], :password => conn['password'], :vhost => conn['vhost'], :port => conn['port'])
        res.start

        sleep(0.001) until res
        if(opts[:verbose])
                puts "AMQP connected - #{res.inspect}"
        end

        return res
end