Kouhei Sutou
null+****@clear*****
Mon Nov 25 00:57:13 JST 2013
Kouhei Sutou 2013-11-25 00:57:13 +0900 (Mon, 25 Nov 2013) New Revision: 558cbfbde0469b3a5df5b8ba0b6b96c6fad20547 https://github.com/droonga/fluent-plugin-droonga/commit/558cbfbde0469b3a5df5b8ba0b6b96c6fad20547 Message: Put envelope directly into job queu Modified files: lib/droonga/processor.rb Modified: lib/droonga/processor.rb (+2 -3) =================================================================== --- lib/droonga/processor.rb 2013-11-25 00:20:24 +0900 (207d9d9) +++ lib/droonga/processor.rb 2013-11-25 00:57:13 +0900 (d98a927) @@ -50,11 +50,10 @@ module Droonga if synchronous.nil? synchronous =****@handl*****_synchronous?(command) end - message = ["", Time.now.to_f, envelope] if @n_workers.zero? or synchronous - @handler.process(message) + @handler.process(envelope) else - @job_queue.push_message(message) + @job_queue.push_message(envelope) end else $log.trace("proessor: process: ignore #{command}") -------------- next part -------------- HTML����������������������������...Download