lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.10 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.11
- old
+ new
@@ -58,10 +58,11 @@
def run
queue.receive_messages(
max_number_of_messages: @max_number_of_messages,
wait_time_seconds: @wait_time_seconds,
- visibility_timeout: @visibility_timeout
+ visibility_timeout: @visibility_timeout,
+ message_attribute_names: ["All"]
).each do |message|
record = parse_message(message)
message.delete if @delete_message