Sha256: 0a02d93fa22ef9c67a37cfb451bb64110408578b0a965532bde87e096867b2d8

Contents?: true

Size: 1.25 KB

Versions: 5

Compression:

Stored size: 1.25 KB

Contents

# frozen_string_literal: true

module Karafka
  module Routing
    module Features
      class DeadLetterQueue < Base
        # Rules around dead letter queue settings
        class Contract < Contracts::Base
          configure do |config|
            config.error_messages = YAML.safe_load(
              File.read(
                File.join(Karafka.gem_root, 'config', 'errors.yml')
              )
            ).fetch('en').fetch('validations').fetch('topic')
          end

          nested :dead_letter_queue do
            required(:active) { |val| [true, false].include?(val) }
            required(:max_retries) { |val| val.is_a?(Integer) && val >= 0 }
          end

          # Validate topic name only if dlq is active
          virtual do |data, errors|
            next unless errors.empty?

            dead_letter_queue = data[:dead_letter_queue]

            next unless dead_letter_queue[:active]

            topic = dead_letter_queue[:topic]

            # When topic is set to false, it means we just want to skip dispatch on DLQ
            next if topic == false
            next if topic.is_a?(String) && Contracts::TOPIC_REGEXP.match?(topic)

            [[%i[dead_letter_queue topic], :format]]
          end
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
karafka-2.0.23 lib/karafka/routing/features/dead_letter_queue/contract.rb
karafka-2.0.22 lib/karafka/routing/features/dead_letter_queue/contract.rb
karafka-2.0.21 lib/karafka/routing/features/dead_letter_queue/contract.rb
karafka-2.0.20 lib/karafka/routing/features/dead_letter_queue/contract.rb
karafka-2.0.19 lib/karafka/routing/features/dead_letter_queue/contract.rb