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

@@ -106,9 +106,13 @@
 
       compat_parameters_convert(conf, :inject)
 
       super
 
+      if @auth_mech && !Mongo::Auth::SOURCES.has_key?(@auth_mech.to_sym)
+        raise Fluent::ConfigError, Mongo::Auth::InvalidMechanism.new(@auth_mech.to_sym)
+      end
+
       if @connection_string.nil? && @database.nil?
         raise Fluent::ConfigError,  "connection_string or database parameter is required"
       end
 
       unless @ignore_invalid_record