class Kiev::AwsSns::ContextInjector

Public Instance Methods

call(message_attributes = {}) click to toggle source

@param [Hash] message_attributes Injects context headers @return [Hash]

# File lib/kiev/aws_sns/context_injector.rb, line 11
def call(message_attributes = {})
  Kiev::SubrequestHelper.payload.each do |key, value|
    message_attributes[key] = {
      data_type: "String",
      string_value: value.to_s
    }
  end
  message_attributes
end