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 |