lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.15 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.16

- old
+ new

@@ -59,11 +59,11 @@ def run queue.receive_messages( max_number_of_messages: @max_number_of_messages, wait_time_seconds: @wait_time_seconds, visibility_timeout: @visibility_timeout, - attribute_names: ["All"], # Receive all available built-in message attributes. - message_attribute_names: ["Component", "component"] # Receive any custom message attributes. + attribute_names: [".*"], # Receive all available built-in message attributes. + message_attribute_names: [".*"] # Receive any custom message attributes. ).each do |message| record = parse_message(message) message.delete if @delete_message