Sha256: d21a322ffa728e67974b5962c4d5df32605c081512b2f10442dd096c19b3595f
Contents?: true
Size: 1.54 KB
Versions: 43
Compression:
Stored size: 1.54 KB
Contents
# frozen_string_literal: true
# This Karafka component is a Pro component under a commercial license.
# This Karafka component is NOT licensed under LGPL.
#
# All of the commercial components are present in the lib/karafka/pro directory of this
# repository and their usage requires commercial license agreement.
#
# Karafka has also commercial-friendly license, commercial support and commercial components.
#
# By sending a pull request to the pro components, you are agreeing to transfer the copyright of
# your code to Maciej Mensfeld.
module Karafka
module Pro
module Cleaner
module Messages
# Extensions to the messages batch allowing for automatic cleaning of each message after
# message is processed.
module Messages
# @param clean [Boolean] do we want to clean each message after we're done working with
# it.
# @yield block we want to execute per each message
#
# @note Cleaning messages after we're done with each of them and did not fail does not
# affect any other functionalities. The only thing that is crucial is to make sure,
# that if DLQ is used, that we mark each message as consumed when using this API as
# otherwise a cleaned message may be dispatched and that should never happen
def each(clean: false)
@messages_array.each do |message|
yield(message)
next unless clean
message.clean!
end
end
end
end
end
end
end
Version data entries
43 entries across 43 versions & 1 rubygems