lib/fluent/plugin/in_sqs.rb in fluent-plugin-sqs-rws-3.0.7 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-sqs-rws-3.0.8
- old
+ new
@@ -68,9 +68,10 @@
def parse_message(message)
obj = {}
message.attributes.each do |key, value|
obj[key] = value.to_s
+ puts "#{key}:#{value}"
end
obj['body'] = message.body.to_s,
obj['receipt_handle'] = message.receipt_handle.to_s,
obj['message_id'] = message.message_id.to_s,
obj['md5_of_body'] = message.md5_of_body.to_s,