Module: Ragnar
- Defined in:
- lib/ragnar/connector.rb,
lib/ragnar.rb,
lib/ragnar/version.rb,
lib/ragnar/exchange.rb,
lib/ragnar/simple_queue.rb
Overview
Provide a simple connector piece that runs EM and passes through AMQP connection options
Defined Under Namespace
Classes: Config, Connector, Exchange, SimpleQueue
Constant Summary collapse
- VERSION =
"0.2.3"
Class Method Summary collapse
- .exchange(type, name, options = {}) {|x| ... } ⇒ Object
- .log_message(level, message, params = {}) ⇒ Object
Class Method Details
.exchange(type, name, options = {}) {|x| ... } ⇒ Object
10 11 12 13 14 |
# File 'lib/ragnar.rb', line 10 def exchange type, name, ={} x = Ragnar::Exchange.new(type, name, ) yield(x) if block_given? x end |
.log_message(level, message, params = {}) ⇒ Object
67 68 69 70 71 72 73 74 75 76 77 78 |
# File 'lib/ragnar.rb', line 67 def self.(level, , params={}) ::Ragnar::Config.logger.send(level, ) rescue => e $stdout << <<-LOG No Logger found in ::Ragnar::log_message Attempted to Log: message : #{} params : #{params} LOG $stdout << $/ end |