# File lib/nanite/amqp.rb, line 54 def start_amqp(options) connection = AMQP.connect({ :user => options[:user], :pass => options[:pass], :vhost => options[:vhost], :host => options[:host], :port => (options[:port] || ::AMQP::PORT).to_i, :insist => options[:insist] || false, :retry => options[:retry] || 5, :connection_status => options[:connection_callback] || proc {|event| Nanite::Log.debug("Connected to MQ") if event == :connected Nanite::Log.debug("Disconnected from MQ") if event == :disconnected } }) MQ.new(connection) end