Daijiro MORI
null+****@clear*****
Fri Apr 26 10:58:14 JST 2013
Daijiro MORI 2013-04-26 10:58:14 +0900 (Fri, 26 Apr 2013) New Revision: 4e2f3f1f7ad284ec2723fb4e34291a4573b1963a https://github.com/groonga/fluent-plugin-droonga/commit/4e2f3f1f7ad284ec2723fb4e34291a4573b1963a Message: Change the signature of parse_message() for convenience. Modified files: lib/droonga/worker.rb Modified: lib/droonga/worker.rb (+5 -8) =================================================================== --- lib/droonga/worker.rb 2013-04-26 10:56:23 +0900 (68cbefa) +++ lib/droonga/worker.rb 2013-04-26 10:58:14 +0900 (d5e00e4) @@ -58,11 +58,8 @@ module Droonga end def dispatch(*message) - parse_message(message) - post_or_push(message, - envelope["body"], - "type" => envelope["type"], - "arguments" => envelope["arguments"]) + body, type, arguments = parse_message(message) + post_or_push(message, body, "type" => type, "arguments" => arguments) end def add_handler(name) @@ -155,6 +152,7 @@ module Droonga } end envelope["via"] ||= [] + [envelope["body"], envelope["type"], envelope["arguments"]] end def push_message(message) @@ -189,10 +187,9 @@ module Droonga message = pull_message next unless message parse_message(message) - command = envelope["type"] + body, command, arguments = parse_message(message) handler = find_handler(command) - arguments = envelope["arguments"] - handler.handle(command, envelope["body"], *arguments) if handler + handler.handle(command, body, *arguments) if handler end end -------------- next part -------------- HTML����������������������������...Download