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