class Karafka::Cli::Worker
Public Instance Methods
call(*params)
click to toggle source
Start the Karafka
Sidekiq worker @param params [Array<String>] additional params that will be passed to sidekiq, that way we
can override any default Karafka settings
# File lib/karafka/cli/worker.rb, line 14 def call(*params) puts 'Starting Karafka worker' config = "-C #{Karafka::App.root.join('config/sidekiq.yml')}" req = "-r #{Karafka.boot_file}" env = "-e #{Karafka.env}" cli.info cmd = "bundle exec sidekiq #{env} #{req} #{config} #{params.join(' ')}" puts(cmd) exec(cmd) end