Sha256: cc7b3860c65a3e3e73237f72229a6d61cf1cf4f681c15e253acd54019dfd7202

Contents?: true

Size: 416 Bytes

Versions: 4

Compression:

Stored size: 416 Bytes

Contents

require "yaml"

module AMQP
  module Integration
    class Rails

      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
    end # Rails
  end # Integration
end # AMQP

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
amqp-0.8.2 lib/amqp/integration/rails.rb
amqp-0.8.1 lib/amqp/integration/rails.rb
amqp-0.8.0 lib/amqp/integration/rails.rb
amqp-0.8.0.rc15 lib/amqp/integration/rails.rb