lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.18 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.19

@@ -82,18 +82,15 @@
         'message_id' => message.message_id.to_s,
         'md5_of_body' => message.md5_of_body.to_s,
         'queue_url' => message.queue_url.to_s,
         'all_obj' => message.attributes.to_s,
         'all_obj2' => message.message_attributes.to_s,
-        'all_obj3' => message.message_attributes["String"].to_s
+        'all_obj3' => message.message_attributes["Component"].to_s
       }
 
       if @attribute_name_to_extract.to_s.strip.length > 0
-        print message.attributes[@attribute_name_to_extract].to_s
-        print message.attributes['Component'].to_s
-        print message.attributes['component'].to_s
-
-        record[@attribute_name_to_extract] = message.attributes[@attribute_name_to_extract].to_s
+        
+        record[@attribute_name_to_extract] = message.message_attributes[@attribute_name_to_extract].to_s
         record['testing'] = message.attributes['Component'].to_s
         record['testing2'] = message.attributes['component'].to_s
       end
       
       record