Class: AMQP::Integration::Rails

Inherits:
Object
  • Object
show all
Defined in:
lib/amqp/integration/rails.rb

Class Method Summary collapse

Class Method Details

.start(options = {}, &block) ⇒ Object 



7
8
9
10
11
12
13
14
 
# File 'lib/amqp/integration/rails.rb', line 7

def self.start(options = {}, &block)
  yaml     = YAML.load_file(File.join(::Rails.root, "config", "amqp.yml"))
  settings = yaml.fetch(::Rails.env, Hash.new).symbolize_keys

  EventMachine.next_tick do
    AMQP.start(settings.merge(options), &block)
  end
end