Contents

# frozen_string_literal: true

require 'deimos/kafka_message'

module Deimos
  module Backends
    # Backend which saves messages to the database instead of immediately
    # sending them.
    class Db < Deimos::PublishBackend
      class << self
        # :nodoc:
        def execute(producer_class:, messages:)
          records = messages.map do |m|
            message = Deimos::KafkaMessage.new(
              message: m.encoded_payload.to_s.b,
              topic: m.topic,
              partition_key: m.partition_key || m.key
            )
            message.key = m.encoded_key.to_s.b unless producer_class.config[:no_keys]
            message
          end
          Deimos::KafkaMessage.import(records)
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 2 rubygems

Version	Path
deimos-ruby-1.0.0.pre.beta23	lib/deimos/backends/db.rb
deimos-ruby-1.0.0.pre.beta22	lib/deimos/backends/db.rb
deimos-kafka-1.0.0.pre.beta21	lib/deimos/backends/db.rb
deimos-kafka-1.0.0.pre.beta20	lib/deimos/backends/db.rb
deimos-kafka-1.0.0.pre.beta19	lib/deimos/backends/db.rb
deimos-kafka-1.0.0.pre.beta18	lib/deimos/backends/db.rb
deimos-kafka-1.0.0.pre.beta17	lib/deimos/backends/db.rb
deimos-kafka-1.0.0.pre.beta16	lib/deimos/backends/db.rb
deimos-kafka-1.0.0.pre.beta15	lib/deimos/backends/db.rb