lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.8 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.9

@@ -81,10 +81,10 @@
         'md5_of_body' => message.md5_of_body.to_s,
         'queue_url' => message.queue_url.to_s
       }
 
       if @attribute_name_to_extract.to_s.strip.length > 0
-        record[@attribute_name_to_extract] = message.attributes[attribute_name_to_extract].to_s
+        record[@attribute_name_to_extract] = message.attributes[@attribute_name_to_extract].to_s
       end
       
       record
     end
   end