Contents

# frozen_string_literal: true

module Rimless
  # The base consumer job where each message is processed asynchronous via
  # Sidekiq. We need to inherit the Karafka base worker class into a custom
  # one, otherwise it fails.
  class ConsumerJob < ::Karafka::BaseWorker
    sidekiq_options queue: Rimless.configuration.consumer_job_queue
  end
end

Version data entries

24 entries across 24 versions & 1 rubygems

Version	Path
rimless-1.8.0	lib/rimless/consumer_job.rb
rimless-1.7.7	lib/rimless/consumer_job.rb
rimless-1.7.6	lib/rimless/consumer_job.rb
rimless-1.7.5	lib/rimless/consumer_job.rb
rimless-1.7.4	lib/rimless/consumer_job.rb
rimless-1.7.3	lib/rimless/consumer_job.rb
rimless-1.7.2	lib/rimless/consumer_job.rb
rimless-1.7.1	lib/rimless/consumer_job.rb
rimless-1.7.0	lib/rimless/consumer_job.rb
rimless-1.6.0	lib/rimless/consumer_job.rb
rimless-1.5.1	lib/rimless/consumer_job.rb
rimless-1.5.0	lib/rimless/consumer_job.rb
rimless-1.4.2	lib/rimless/consumer_job.rb
rimless-1.4.1	lib/rimless/consumer_job.rb
rimless-1.4.0	lib/rimless/consumer_job.rb
rimless-1.3.0	lib/rimless/consumer_job.rb
rimless-1.2.0	lib/rimless/consumer_job.rb
rimless-1.1.1	lib/rimless/consumer_job.rb
rimless-1.1.0	lib/rimless/consumer_job.rb
rimless-1.0.4	lib/rimless/consumer_job.rb