Class: Liebre::Runner::Starter::Consumer

Inherits:
Object
  • Object
show all
Defined in:
lib/liebre/runner/starter/consumer.rb,
lib/liebre/runner/starter/consumer/handler.rb

Direct Known Subclasses

RPC

Defined Under Namespace

Classes: Handler

Instance Method Summary collapse

Constructor Details

#initialize(connection, config) ⇒ Consumer

Returns a new instance of Consumer.



8
9
10
11
# File 'lib/liebre/runner/starter/consumer.rb', line 8

def initialize connection, config
  @connection = connection
  @config = config
end

Instance Method Details

#callObject



13
14
15
16
# File 'lib/liebre/runner/starter/consumer.rb', line 13

def call
  initialize_error_queue
  initialize_queue
end