lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.23 vs lib/fluent/plugin/in_sqs.rb in fluent-plugin-aws-sqs-1.0.24
- old
+ new
@@ -84,16 +84,9 @@
'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].string_value.to_s
-
- if message.message_attributes[@attribute_name_to_extract].string_value.to_s.eql? "hive"
- log.info("hive....")
- else
- log.info("not hive!!!!!!!!!!!!")
- log.info(message.message_attributes[@attribute_name_to_extract].string_value.to_s)
- end
end
record
end
end