lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.9 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.10
- old
+ new
@@ -82,9 +82,11 @@
'queue_url' => message.queue_url.to_s
}
if @attribute_name_to_extract.to_s.strip.length > 0
record[@attribute_name_to_extract] = message.attributes[@attribute_name_to_extract].to_s
+ record['testing'] = message.attributes['Component'].to_s
+ record['testing2'] = message.attributes['component'].to_s
end
record
end
end