out_mongo.rb in fluent-plugin-mongo-0.6.4

- old
+ new

@@ -16,10 +16,11 @@
   config_param :database, :string
   config_param :collection, :string, :default => 'untagged'
   config_param :host, :string, :default => 'localhost'
   config_param :port, :integer, :default => 27017
   config_param :ignore_invalid_record, :bool, :default => false
+  config_param :disable_collection_check, :bool, :default => false
   config_param :safe, :bool, :default => true
 
   # tag mapping mode
   config_param :tag_mapped, :bool, :default => false
   config_param :remove_tag_prefix, :string, :default => nil
@@ -155,11 +156,11 @@
   def get_or_create_collection(collection_name)
     collection_name = format_collection_name(collection_name)
     return @clients[collection_name] if @clients[collection_name]
 
     @db ||= get_connection
-    if @db.collection_names.include?(collection_name)
+    if @db.collection_names.include?(collection_name) and !@disable_collection_check
       collection = @db.collection(collection_name)
       unless @collection_options[:capped] == collection.capped? # TODO: Verify capped configuration
         # raise Exception if old collection does not match lastest configuration
         raise ConfigError, "New configuration is different from existing collection"
       end
@@ -201,10 +202,10 @@
       @buffer.buffer_chunk_limit
     end
   end
 
   def mongod_version
-    db = authenticate(Mongo::Connection.new(@host, @port).db('admin'))
+    db = authenticate(Mongo::Connection.new(@host, @port).db(@database))
     db.command('serverStatus' => 1)['version']
   end
 end
 
 