Contents

# frozen_string_literal: true

class Freddy
  module Producers
    class ReplyProducer
      CONTENT_TYPE = 'application/json'

      def initialize(channel, logger)
        @logger = logger
        @exchange = channel.default_exchange
      end

      def produce(routing_key, payload, properties)
        span = Tracing.span_for_produce(
          @exchange,
          routing_key,
          payload,
          correlation_id: properties[:correlation_id]
        )

        properties = properties.merge(
          routing_key: routing_key,
          content_type: CONTENT_TYPE
        )
        Tracing.inject_tracing_information_to_properties!(properties)

        @exchange.publish Payload.dump(payload), properties
      ensure
        # We won't wait for a reply. Just finish the span immediately.
        span.finish
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
freddy-2.2.3	lib/freddy/producers/reply_producer.rb
freddy-2.2.2	lib/freddy/producers/reply_producer.rb
freddy-2.2.1	lib/freddy/producers/reply_producer.rb
freddy-2.2.0	lib/freddy/producers/reply_producer.rb
freddy-2.1.0	lib/freddy/producers/reply_producer.rb
freddy-2.0.0	lib/freddy/producers/reply_producer.rb