Daijiro MORI
null+****@clear*****
Thu Jul 4 17:59:11 JST 2013
Daijiro MORI 2013-07-04 17:59:11 +0900 (Thu, 04 Jul 2013) New Revision: 7d7ce144226da470f844e68d510c870931199c15 https://github.com/groonga/fluent-plugin-droonga/commit/7d7ce144226da470f844e68d510c870931199c15 Message: Delete pulled records. Modified files: lib/droonga/worker.rb Modified: lib/droonga/worker.rb (+4 -1) =================================================================== --- lib/droonga/worker.rb 2013-06-26 07:34:35 +0900 (0c86d9a) +++ lib/droonga/worker.rb 2013-07-04 17:59:11 +0900 (aa731c9) @@ -192,7 +192,10 @@ module Droonga @status = :IDLE @queue.pull do |record| @status = :BUSY - packed_message = record.message if record + if record + packed_message = record.message + record.delete + end end return nil unless packed_message MessagePack.unpack(packed_message) -------------- next part -------------- HTML����������������������������...Download