module Ocular::DSL::RabbitMQ
Public Instance Methods
amqp()
click to toggle source
# File lib/ocular/dsl/rabbitmq.rb, line 10 def amqp() datasources = ::Ocular::Settings::get(:datasources) if !datasources or !datasources[:rabbitmq] raise "No rabbitmq client settings" end settings = datasources[:rabbitmq] || {} conn = Bunny.new(settings[:url] || nil) conn.start return conn.create_channel end