Merge pull request #114 from fluent/pass-chunk-directly-instead-of-chunk-metadata

Pass chunk directly instead of chunk.metadata

Author: repeatedly

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"

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