Class: Liebre::Runner::Starter::RPC

Inherits:
Consumer
  • Object
show all
Defined in:
lib/liebre/runner/starter/rpc.rb

Instance Method Summary collapse

Methods inherited from Consumer

#initialize

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, meta, payload|
    begin
      logger.debug "Liebre: Received message for #{klass.name}: #{payload} - #{meta}"
      consumer = klass.new(payload, meta, callback(meta))
      consumer.call
    rescue => e
      logger.error e.inspect
      logger.error e.backtrace.join("\n")
    end
  end
end