Sha256: 6780666670d74616d7344b492e1fa4136bc54bd431f5ec91ddcca6c318938bd8
Contents?: true
Size: 612 Bytes
Versions: 48
Compression:
Stored size: 612 Bytes
Contents
require "yaml"
module AMQP
module Integration
class Rails
def self.start(options_or_uri = {}, &block)
yaml = YAML.load_file(File.join(::Rails.root, "config", "amqp.yml"))
settings = yaml.fetch(::Rails.env, Hash.new).symbolize_keys
arg = if options_or_uri.is_a?(Hash)
settings.merge(options_or_uri)[:uri]
else
settings[:uri] || options_or_uri
end
EventMachine.next_tick do
AMQP.start(arg, &block)
end
end
end # Rails
end # Integration
end # AMQP
Version data entries
48 entries across 48 versions & 1 rubygems