diff --git a/lib/fluent/plugin/in_mongo_tail.rb b/lib/fluent/plugin/in_mongo_tail.rb index 89b58bc..7e3aa6c 100644 --- a/lib/fluent/plugin/in_mongo_tail.rb +++ b/lib/fluent/plugin/in_mongo_tail.rb @@ -69,6 +69,8 @@ def configure(conf) raise Fluent::ConfigError, "One of 'database' or 'url' must be specified" end + date = Time.now + @collection = date.strftime(collection) @last_id = @id_store_file ? get_last_id : nil @connection_options[:ssl] = @ssl