Kouhei Sutou
null+****@clear*****
Tue Dec 24 19:23:51 JST 2013
Kouhei Sutou 2013-12-24 19:23:51 +0900 (Tue, 24 Dec 2013) New Revision: 25ca7dea9f4918c669127bd8cf5b76bf10c0f692 https://github.com/droonga/fluent-plugin-droonga/commit/25ca7dea9f4918c669127bd8cf5b76bf10c0f692 Message: Use "message" not "envelope" Modified files: lib/droonga/handler.rb Modified: lib/droonga/handler.rb (+6 -6) =================================================================== --- lib/droonga/handler.rb 2013-12-24 19:09:18 +0900 (d6f072f) +++ lib/droonga/handler.rb 2013-12-24 19:23:51 +0900 (b9b3ffb) @@ -59,23 +59,23 @@ module Droonga find_plugin(command).prefer_synchronous?(command) end - def process(envelope) + def process(message) $log.trace("#{log_tag}: process: start") - body, command, arguments = parse_envelope(envelope) + body, command, arguments = parse_message(message) plugin = find_plugin(command) if plugin.nil? $log.trace("#{log_tag}: process: done: no plugin: <#{command}>") return end - process_command(plugin, command, envelope, arguments) + process_command(plugin, command, message, arguments) $log.trace("#{log_tag}: process: done: <#{command}>", :plugin => plugin.class) end private - def parse_envelope(envelope) - @envelope = envelope - [envelope["body"], envelope["type"], envelope["arguments"]] + def parse_message(message) + @envelope = message + [message["body"], message["type"], message["arguments"]] end def prepare -------------- next part -------------- HTML����������������������������...다운로드
