Class: Liebre::Runner

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

Defined Under Namespace

Classes: Consumers, Starter

Constant Summary collapse

RETRY_INTERVAL = 
5

Instance Method Summary collapse

Constructor Details

#initialize(retry_interval = RETRY_INTERVAL) ⇒ Runner

Returns a new instance of Runner.



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

def initialize retry_interval = RETRY_INTERVAL
  @retry_interval = retry_interval
end

Instance Method Details

#start ⇒ Object 



13
14
15
16
17
18
19
20
21
 
# File 'lib/liebre/runner.rb', line 13

def start
  setup_shutdown
  connection_manager.restart
  start_consumers
  sleep
rescue StandardError => e
  log_and_wait(e)
  retry
end