Contents

# frozen_string_literal: true

require "kiev/aws_sns/context_injector"

module Kiev
  module Shoryuken
    module Middleware
      class MessageTracer
        def call(options)
          options[:message_attributes] ||= {}
          Kiev::AwsSns::ContextInjector.new.call(options[:message_attributes])
          yield
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
kiev-4.9.0	lib/kiev/shoryuken/middleware/message_tracer.rb
kiev-4.8.3	lib/kiev/shoryuken/middleware/message_tracer.rb
kiev-4.8.2	lib/kiev/shoryuken/middleware/message_tracer.rb
kiev-4.8.1	lib/kiev/shoryuken/middleware/message_tracer.rb
kiev-4.8.0	lib/kiev/shoryuken/middleware/message_tracer.rb
kiev-4.7.0	lib/kiev/shoryuken/middleware/message_tracer.rb
kiev-4.6.0	lib/kiev/shoryuken/middleware/message_tracer.rb
kiev-4.5.0	lib/kiev/shoryuken/middleware/message_tracer.rb