Sha256: 5465150cf1f1a2959a40c03ea1f5df1d18d910b549ccf69d5b3d36125c3a4140

Contents?: true

Size: 1015 Bytes

Versions: 16

Compression:

Stored size: 1015 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Messages
    module Builders
      # Builder for creating message batch instances.
      module Messages
        class << self
          # Creates messages batch with messages inside based on the incoming messages and the
          # topic from which it comes.
          #
          # @param messages [Array<Karafka::Messages::Message>] karafka messages array
          # @param topic [Karafka::Routing::Topic] topic for which we're received messages
          # @param received_at [Time] moment in time when the messages were received
          # @return [Karafka::Messages::Messages] messages batch object
          def call(messages, topic, received_at)
            metadata = BatchMetadata.call(
              messages,
              topic,
              received_at
            ).freeze

            Karafka::Messages::Messages.new(
              messages,
              metadata
            ).freeze
          end
        end
      end
    end
  end
end

Version data entries

16 entries across 16 versions & 1 rubygems

Version Path
karafka-2.0.5 lib/karafka/messages/builders/messages.rb
karafka-2.0.4 lib/karafka/messages/builders/messages.rb
karafka-2.0.3 lib/karafka/messages/builders/messages.rb
karafka-2.0.2 lib/karafka/messages/builders/messages.rb
karafka-2.0.1 lib/karafka/messages/builders/messages.rb
karafka-2.0.0 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.rc6 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.rc5 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.rc4 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.rc3 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.rc2 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.rc1 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.beta5 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.beta4 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.beta3 lib/karafka/messages/builders/messages.rb
karafka-2.0.0.beta2 lib/karafka/messages/builders/messages.rb