lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.14 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.15
- old
+ new
@@ -60,10 +60,10 @@
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: ["All"] # Receive any custom message attributes.
+ message_attribute_names: ["Component", "component"] # Receive any custom message attributes.
).each do |message|
record = parse_message(message)
message.delete if @delete_message