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.0.3	lib/rimless/consumer_job.rb
rimless-1.0.2	lib/rimless/consumer_job.rb
rimless-1.0.1	lib/rimless/consumer_job.rb
rimless-1.0.0	lib/rimless/consumer_job.rb