Class: Warren::App::ConsumerStart

Inherits:

Object

• Object
• Warren::App::ConsumerStart

Defined in:

lib/warren/app/consumer_start.rb

Overview

Handles the initial creation of the configuration object

Class Method Summary

• .invoke(shell, options) ⇒ Void

  Starts up a warren client process for the configured consumers.

Instance Method Summary

• #initialize(shell, options) ⇒ ConsumerStart constructor

  A new instance of ConsumerStart.

• #invoke ⇒ Void

  Starts up a warren client process for the configured consumers.

Constructor Details

#initialize(shell, options) ⇒ ConsumerStart

Returns a new instance of ConsumerStart.

# File 'lib/warren/app/consumer_start.rb', line 25

def initialize(shell, options)
  @shell = shell
  @config = Warren::Config::Consumers.new(options[:path])
  @consumers = options[:consumers]
end

Class Method Details

.invoke(shell, options) ⇒ Void

Starts up a warren client process for the configured consumers.

Parameters:

• shell (Thor::Shell::Basic) —

  Thor shell instance for feedback

• options (Hash) —

  Hash of command line arguments from Thor

Options Hash (options):

• :path (String) —

  Path to the ‘warren_consumers.yml `file

• :consumers (Array<String>) —

  Array of configured consumers to start. Defaults to all consumers

Returns:

• (Void)

# File 'lib/warren/app/consumer_start.rb', line 21

def self.invoke(shell, options)
  new(shell, options).invoke
end

Instance Method Details

#invoke ⇒ Void

Starts up a warren client process for the configured consumers.

Returns:

• (Void)

# File 'lib/warren/app/consumer_start.rb', line 35

def invoke
  Warren::Client.new(@config, consumers: @consumers).run
end