out_mongo.rb in fluent-plugin-mongo-0.7.5

- old
+ new

@@ -17,10 +17,11 @@
     config_param :port, :integer, :default => 27017
     config_param :ignore_invalid_record, :bool, :default => false
     config_param :disable_collection_check, :bool, :default => nil
     config_param :exclude_broken_fields, :string, :default => nil
     config_param :write_concern, :integer, :default => nil
+    config_param :journaled, :bool, :default => false
     config_param :replace_dot_in_key_with, :string, :default => nil
     config_param :replace_dollar_in_key_with, :string, :default => nil
 
     # tag mapping mode
     config_param :tag_mapped, :bool, :default => false
@@ -68,9 +69,10 @@
         @collection_options[:size] = Config.size_value(conf['capped_size'])
         @collection_options[:max] = Config.size_value(conf['capped_max']) if conf.has_key?('capped_max')
       end
 
       @connection_options[:w] = @write_concern unless @write_concern.nil?
+      @connection_options[:j] = @journaled
       @connection_options[:ssl] = @ssl
 
       # MongoDB uses BSON's Date for time.
       def @timef.format_nocache(time)
         time