lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.13 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.14
- old
+ new
@@ -79,17 +79,18 @@
record = {
'body' => message.body.to_s,
'receipt_handle' => message.receipt_handle.to_s,
'message_id' => message.message_id.to_s,
'md5_of_body' => message.md5_of_body.to_s,
- 'queue_url' => message.queue_url.to_s
+ 'queue_url' => message.queue_url.to_s,
+ 'all_obj' => message.attributes.to_s
}
if @attribute_name_to_extract.to_s.strip.length > 0
print message.attributes[@attribute_name_to_extract].to_s
print message.attributes['Component'].to_s
print message.attributes['component'].to_s
-
+
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