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