YUKI Hiroshi
null+****@clear*****
Fri Jan 24 17:20:23 JST 2014
YUKI Hiroshi 2014-01-24 17:20:23 +0900 (Fri, 24 Jan 2014) New Revision: e8377aa701c83e9b626d1ee3b4d22aa267b0c56b https://github.com/droonga/fluent-plugin-droonga/commit/e8377aa701c83e9b626d1ee3b4d22aa267b0c56b Message: Override broadcaster() instead of scatter(). Because Groonga commands uses broadcast_all(). Modified files: lib/droonga/plugin/distributor/groonga.rb Modified: lib/droonga/plugin/distributor/groonga.rb (+4 -4) =================================================================== --- lib/droonga/plugin/distributor/groonga.rb 2014-01-24 17:19:08 +0900 (717b6cb) +++ lib/droonga/plugin/distributor/groonga.rb 2014-01-24 17:20:23 +0900 (b2d09e9) @@ -43,10 +43,10 @@ module Droonga end private - def scatterer(message, key) - scatterer = super - scatterer["outputs"] << "result" - scatterer + def broadcaster(message) + broadcaster = super + broadcaster["outputs"] << "result" + broadcaster end def reducer(message) -------------- next part -------------- HTML����������������������������...ダウンロード
