Class: Liebre::Runner::Starter::RPC
- Defined in:
- lib/liebre/runner/starter/rpc.rb
Instance Method Summary collapse
Methods inherited from Consumer
Constructor Details
This class inherits a constructor from Liebre::Runner::Starter::Consumer
Instance Method Details
#call ⇒ Object
6 7 8 9 10 11 12 13 14 15 16 17 |
# File 'lib/liebre/runner/starter/rpc.rb', line 6 def call queue.subscribe(:manual_ack => false) do |_info, , payload| begin logger.debug "Liebre: Received message for #{klass.name}: #{payload} - #{}" consumer = klass.new(payload, , callback()) consumer.call rescue => e logger.error e.inspect logger.error e.backtrace.join("\n") end end end |