Contents

module Deimos
  class ConsumerRoute < Karafka::Routing::Features::Base
    module Topic

      FIELDS = %i(max_db_batch_size
                  bulk_import_id_column
                  replace_associations
                  bulk_import_id_generator
                  each_message
                  reraise_errors
                  fatal_error
                  save_associations_first
      )
      Config = Struct.new(*FIELDS, keyword_init: true)

      FIELDS.each do |field|
        define_method(field) do |*args|
          @deimos_config ||= Config.new(
            bulk_import_id_column: :bulk_import_id,
            replace_associations: true,
            each_message: false,
            bulk_import_id_generator: proc { SecureRandom.uuid },
            fatal_error: proc { false }
          )
          if args.any?
            @deimos_config.public_send("#{field}=", args[0])
          end
          @deimos_config[field]
        end
      end
    end
  end
end

Deimos::ConsumerRoute.activate

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
deimos-ruby-2.0.0.pre.alpha2	lib/deimos/ext/consumer_route.rb
deimos-ruby-2.0.0.pre.alpha1	lib/deimos/ext/consumer_route.rb