Sha256: a85eaf84202691e5d4975ab7554abeae38cc41d3dd09e466d66b0b8c40b2de36
Contents?: true
Size: 497 Bytes
Versions: 6
Compression:
Stored size: 497 Bytes
Contents
# frozen_string_literal: true
require "kiev/context_reader"
module Kiev
module Shoryuken
class ContextReader < Kiev::ContextReader
def initialize(message)
super
@message_attributes = message.message_attributes
end
def [](key)
return unless @message_attributes.key?(key)
attribute_value = @message_attributes[key]
return unless attribute_value.data_type == "String"
attribute_value.string_value
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems