Sha256: a8d1ba45fdaded04d8a720cd586f534ba77dc77796641112370fa1df7ac4acdb
Contents?: true
Size: 491 Bytes
Versions: 56
Compression:
Stored size: 491 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Routing
module Features
class DeadLetterQueue < Base
# Config for dead letter queue feature
Config = Struct.new(
:active,
# We add skip variants but in regular we support only `:one`
:max_retries,
# To what topic the skipped messages should be moved
:topic,
keyword_init: true
) { alias_method :active?, :active }
end
end
end
end
Version data entries
56 entries across 56 versions & 1 rubygems