Kouhei Sutou
null+****@clear*****
Fri Dec 20 17:38:26 JST 2013
Kouhei Sutou 2013-12-20 17:38:26 +0900 (Fri, 20 Dec 2013) New Revision: f4e2a98ba5c709931d0bb11b88e7d8854e6e0d21 https://github.com/droonga/fluent-plugin-droonga/commit/f4e2a98ba5c709931d0bb11b88e7d8854e6e0d21 Message: Use "message" instead of "envelope" Modified files: lib/droonga/distributor_plugin.rb Modified: lib/droonga/distributor_plugin.rb (+8 -8) =================================================================== --- lib/droonga/distributor_plugin.rb 2013-12-20 17:26:25 +0900 (37380fd) +++ lib/droonga/distributor_plugin.rb 2013-12-20 17:38:26 +0900 (119a637) @@ -30,11 +30,11 @@ module Droonga @distributor.distribute(message) end - def scatter_all(envelope, key) + def scatter_all(message, key) message = [{ - "command"=> envelope["type"], - "dataset"=> envelope["dataset"], - "body"=> envelope["body"], + "command"=> message["type"], + "dataset"=> message["dataset"], + "body"=> message["body"], "key"=> key, "type"=> "scatter", "replica"=> "all", @@ -43,11 +43,11 @@ module Droonga distribute(message) end - def broadcast_all(envelope) + def broadcast_all(message) distribute_message = [{ - "command"=> envelope["type"], - "dataset"=> envelope["dataset"], - "body"=> envelope["body"], + "command"=> message["type"], + "dataset"=> message["dataset"], + "body"=> message["body"], "type"=> "broadcast", "replica"=> "all", "post"=> true -------------- next part -------------- HTML����������������������������...Télécharger
