YUKI Hiroshi
null+****@clear*****
Mon Feb 3 12:33:13 JST 2014
YUKI Hiroshi 2014-02-03 12:33:13 +0900 (Mon, 03 Feb 2014) New Revision: 0d15ee36f99896b2a2261e9f97ad835e3b974024 https://github.com/droonga/fluent-plugin-droonga/commit/0d15ee36f99896b2a2261e9f97ad835e3b974024 Message: Broadcast messages correctly Modified files: lib/droonga/distributor_plugin.rb Modified: lib/droonga/distributor_plugin.rb (+2 -2) =================================================================== --- lib/droonga/distributor_plugin.rb 2014-02-03 12:26:56 +0900 (db6d94d) +++ lib/droonga/distributor_plugin.rb 2014-02-03 12:33:13 +0900 (2ed9c15) @@ -33,7 +33,7 @@ module Droonga def scatter(message, options={}) planner = DistributedCommandPlanner.new(message) - planner.scatter + planner.scatter(nil) planner.key = options[:key] planner.reduce(options[:reduce]) planner.plan @@ -42,7 +42,7 @@ module Droonga def broadcast(message, options={}) planner = DistributedCommandPlanner.new(message) - planner.broadcast(:write => options[:write]) + planner.broadcast(nil, :write => options[:write]) planner.reduce(options[:reduce]) planner.plan distribute(planner.messages) -------------- next part -------------- HTML����������������������������...Download