Sha256: 8ec05146c9aea22aab1a53f9a42e21df1f9f41109b41cbff59b546c90a228148
Contents?: true
Size: 1.03 KB
Versions: 6
Compression:
Stored size: 1.03 KB
Contents
# frozen_string_literal: true
module Karafka
module Extensions
# Additional Karafka::Routing::Topic methods that are required to work with Sidekiq backend
module SidekiqTopicAttributes
# @return [Class] Class (not an instance) of a worker that should be used to schedule the
# background job
# @note If not provided - will be built based on the provided consumer
def worker
@worker ||= backend == :sidekiq ? Karafka::Workers::Builder.new(consumer).build : nil
end
# @return [Class] Interchanger class (not an instance) that we want to use to interchange
# params between Karafka server and Karafka background job
def interchanger
@interchanger ||= Karafka::Interchanger.new
end
# Creates attributes writers for worker and interchanger, so they can be overwritten
# @param base [Class] Karafka::Routing::Topic class
def self.included(base)
base.send :attr_writer, :worker
base.send :attr_writer, :interchanger
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems