Contents

# frozen_string_literal: true

module Sbmt
  module KafkaProducer
    class OutboxProducer < Sbmt::KafkaProducer::BaseProducer
      def call(outbox_item, payload)
        sync_publish!(payload, **outbox_item.options)
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
sbmt-kafka_producer-3.2.1	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-3.2.0	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-3.1.1	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-3.1.0	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-3.0.0	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-2.2.3	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-2.2.2	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-2.2.1	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-2.2.0	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-2.1.0	lib/sbmt/kafka_producer/outbox_producer.rb
sbmt-kafka_producer-2.0.0	lib/sbmt/kafka_producer/outbox_producer.rb