lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.20 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.21
- old
+ new
@@ -85,9 +85,12 @@
}
if @attribute_name_to_extract.to_s.strip.length > 0
record[@attribute_name_to_extract] = message.message_attributes[@attribute_name_to_extract].string_value.to_s
end
+
+ log.info("the message is")
+ log.info(record)
record
end
end
end