lib/fluent/plugin/out_mongo.rb in fluent-plugin-mongo-1.2.1 vs lib/fluent/plugin/out_mongo.rb in fluent-plugin-mongo-1.2.2

@@ -170,11 +170,12 @@
     def multi_workers_ready?
       true
     end
 
     def write(chunk)
-      collection_name = extract_placeholders(@collection, chunk.metadata)
-      database_name = extract_placeholders(@database, chunk.metadata)
+      collection_name = extract_placeholders(@collection, chunk)
+      # In connection_string case, we shouldn't handle extract_placeholers for @database.
+      database_name = extract_placeholders(@database, chunk) unless @connection_string
       operate(database_name, format_collection_name(collection_name), collect_records(chunk))
     end
 
     private