Module: Ocular::DSL::RabbitMQ

Included in:
RunContext, Event::DefinitionProxy
Defined in:
lib/ocular/dsl/rabbitmq.rb

Instance Method Summary collapse

Instance Method Details

#amqp ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
 
# 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