diff --git a/fluent-plugin-mongo.gemspec b/fluent-plugin-mongo.gemspec index a6daecd..08b79bf 100644 --- a/fluent-plugin-mongo.gemspec +++ b/fluent-plugin-mongo.gemspec @@ -17,7 +17,7 @@ Gem::Specification.new do |gem| gem.executables = `git ls-files -- bin/*`.split("\n").map{ |f| File.basename(f) } gem.require_paths = ['lib'] - gem.add_dependency "fluentd", [">= 0.14.12", "< 2"] + gem.add_dependency "fluentd", [">= 0.14.22", "< 2"] gem.add_runtime_dependency "mongo", "~> 2.6.0" gem.add_development_dependency "rake", ">= 0.9.2" gem.add_development_dependency "simplecov", ">= 0.5.4" diff --git a/lib/fluent/plugin/out_mongo.rb b/lib/fluent/plugin/out_mongo.rb index ebc4a41..b61a0d0 100644 --- a/lib/fluent/plugin/out_mongo.rb +++ b/lib/fluent/plugin/out_mongo.rb @@ -172,8 +172,8 @@ def multi_workers_ready? end def write(chunk) - collection_name = extract_placeholders(@collection, chunk.metadata) - database_name = extract_placeholders(@database, chunk.metadata) + collection_name = extract_placeholders(@collection, chunk) + database_name = extract_placeholders(@database, chunk) operate(database_name, format_collection_name(collection_name), collect_records(chunk)) end