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