Kouhei Sutou
null+****@clear*****
Fri Dec 20 17:19:13 JST 2013
Kouhei Sutou 2013-12-20 17:19:13 +0900 (Fri, 20 Dec 2013) New Revision: 0f2a422ebbb3a014d0123424ea8089bee40199b4 https://github.com/droonga/fluent-plugin-droonga/commit/0f2a422ebbb3a014d0123424ea8089bee40199b4 Message: Use "message" instead of "envelope" Modified files: lib/droonga/processor.rb Modified: lib/droonga/processor.rb (+4 -4) =================================================================== --- lib/droonga/processor.rb 2013-12-20 17:18:35 +0900 (cb4d8ac) +++ lib/droonga/processor.rb 2013-12-20 17:19:13 +0900 (91d4d02) @@ -37,18 +37,18 @@ module Droonga $log.trace("#{log_tag}: shutdown: done") end - def process(envelope, synchronous=nil) + def process(message, synchronous=nil) $log.trace("#{log_tag}: process: start") - command = envelope["type"] + command = message["type"] if****@handl*****?(command) $log.trace("#{log_tag}: process: handlable: #{command}") if synchronous.nil? synchronous =****@handl*****_synchronous?(command) end if @n_workers.zero? or synchronous - @handler.process(envelope) + @handler.process(message) else - @message_pusher.push(envelope) + @message_pusher.push(message) end else $log.trace("#{log_tag}: process: ignore #{command}") -------------- next part -------------- HTML����������������������������...Download