lib/fluent/plugin/in_sqs.rb in fluent-plugin-sqs-rws-3.0.6 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-sqs-rws-3.0.7
- old
+ new
@@ -75,8 +75,9 @@
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,
obj['queue_url'] = message.queue_url.to_s,
obj['sender_id'] = message.attributes['SenderId'].to_s
+ return obj
end
end
end