Daijiro MORI
null+****@clear*****
Fri Apr 19 15:25:54 JST 2013
Daijiro MORI 2013-04-19 15:25:54 +0900 (Fri, 19 Apr 2013) New Revision: 9cf1f7093da730809078abe51ad90199d5052d1e https://github.com/groonga/fluent-plugin-droonga/commit/9cf1f7093da730809078abe51ad90199d5052d1e Message: Call parse_message() from outside of process_message() Modified files: lib/droonga/worker.rb Modified: lib/droonga/worker.rb (+2 -1) =================================================================== --- lib/droonga/worker.rb 2013-04-19 15:03:33 +0900 (083bc6f) +++ lib/droonga/worker.rb 2013-04-19 15:25:54 +0900 (f1ce870) @@ -59,6 +59,7 @@ module Droonga def dispatch(tag, time, record) if****@pool*****? + parse_message(tag, time, record) process_message(tag, time, record) else post_message(tag, time, record) @@ -113,7 +114,6 @@ module Droonga end def process_message(tag, time, record) - parse_message(tag, time, record) command = envelope["type"] handler = find_handler(command) return unless handler @@ -145,6 +145,7 @@ module Droonga end if packed_message tag, time, record = MessagePack.unpack(packed_message) + parse_message(tag, time, record) process_message(tag, time, record) end @status = :IDLE -------------- next part -------------- HTML����������������������������...Download