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

@@ -79,20 +79,14 @@
       record = {
         'body' => message.body.to_s,
         'receipt_handle' => message.receipt_handle.to_s,
         '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["Component"].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.message_attributes[@attribute_name_to_extract].to_s
-        record['testing'] = message.attributes['Component'].to_s
-        record['testing2'] = message.attributes['component'].to_s
+        record[@attribute_name_to_extract] = message.message_attributes[@attribute_name_to_extract].string_value.to_s
       end
       
       record
     end
   end