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