54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
# 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
|