YUKI Hiroshi
null+****@clear*****
Fri Nov 21 12:37:57 JST 2014
YUKI Hiroshi 2014-11-21 12:37:57 +0900 (Fri, 21 Nov 2014) New Revision: 221a06b49bf1b0653826f571f51c3b8ac5fe7bac https://github.com/droonga/droonga-engine/commit/221a06b49bf1b0653826f571f51c3b8ac5fe7bac Message: Use meaningful status name for last processed message timestamp Modified files: lib/droonga/engine.rb Modified: lib/droonga/engine.rb (+7 -7) =================================================================== --- lib/droonga/engine.rb 2014-11-21 12:32:57 +0900 (72c0f8d) +++ lib/droonga/engine.rb 2014-11-21 12:37:57 +0900 (6602e34) @@ -65,7 +65,7 @@ module Droonga @node_status_observer.stop on_finish = lambda do logger.trace("stop_gracefully/on_finish: start") - save_last_processed_timestamp + save_last_processed_message_timestamp @dispatcher.stop_gracefully do @state.shutdown yield @@ -85,7 +85,7 @@ module Droonga # It may be called after stop_gracefully. def stop_immediately logger.trace("stop_immediately: start") - save_last_processed_timestamp + save_last_processed_message_timestamp @live_nodes_list_observer.stop @node_status_observer.stop @dispatcher.stop_immediately @@ -95,7 +95,7 @@ module Droonga def process(message) return unless effective_message?(message) - @last_processed_timestamp = message["date"] + @last_processed_message_timestamp = message["date"] @dispatcher.process_message(message) end @@ -128,10 +128,10 @@ module Droonga Dispatcher.new(@state, @catalog) end - def save_last_processed_timestamp - logger.trace("output_last_processed_timestamp: start") - node_status.set(:last_processed_timestamp, @last_processed_timestamp.to_s) - logger.trace("output_last_processed_timestamp: done") + def save_last_processed_message_timestamp + logger.trace("output_last_processed_message_timestamp: start") + node_status.set(:last_processed_message_timestamp, @last_processed_message_timestamp.to_s) + logger.trace("output_last_processed_message_timestamp: done") end def effective_message?(message) -------------- next part -------------- HTML����������������������������...下載
