Kouhei Sutou
null+****@clear*****
Thu Dec 19 15:54:55 JST 2013
Kouhei Sutou 2013-12-19 15:54:55 +0900 (Thu, 19 Dec 2013) New Revision: 0a44b92a508a3c78ec190058c00f8963f2669104 https://github.com/droonga/fluent-plugin-droonga/commit/0a44b92a508a3c78ec190058c00f8963f2669104 Message: Use "message" instead of "envelope" Modified files: lib/fluent/plugin/out_droonga.rb Modified: lib/fluent/plugin/out_droonga.rb (+7 -7) =================================================================== --- lib/fluent/plugin/out_droonga.rb 2013-12-19 12:41:09 +0900 (feb0301) +++ lib/fluent/plugin/out_droonga.rb 2013-12-19 15:54:55 +0900 (3c141ce) @@ -52,23 +52,23 @@ module Fluent def parse_record(tag, record) prefix, type, *arguments = tag.split(/\./) if type.nil? || type.empty? || type == 'message' - envelope = record + message = record else - envelope = { + message = { "type" => type, "arguments" => arguments, "body" => record } end - envelope["via"] ||= [] - reply_to = envelope["replyTo"] + message["via"] ||= [] + reply_to = message["replyTo"] if reply_to.is_a? String - envelope["replyTo"] = { - "type" => envelope["type"] + ".result", + message["replyTo"] = { + "type" => message["type"] + ".result", "to" => reply_to } end - envelope + message end end end -------------- next part -------------- HTML����������������������������...Download