YUKI Hiroshi
null+****@clear*****
Tue Apr 21 09:46:49 JST 2015
YUKI Hiroshi 2015-04-21 09:46:49 +0900 (Tue, 21 Apr 2015) New Revision: b51a8f7fa1959ccf00e1b9da09590a3f9eff168f https://github.com/droonga/droonga-engine/commit/b51a8f7fa1959ccf00e1b9da09590a3f9eff168f Message: Set "xSender" field for some special cases, to track messages Modified files: lib/droonga/forward_buffer.rb lib/droonga/plugins/system/absorb_data.rb Modified: lib/droonga/forward_buffer.rb (+1 -0) =================================================================== --- lib/droonga/forward_buffer.rb 2015-04-21 09:46:36 +0900 (a6a93df) +++ lib/droonga/forward_buffer.rb 2015-04-21 09:46:49 +0900 (60e2e75) @@ -107,6 +107,7 @@ module Droonga logger.trace("forward: Forwarding buffered message", :message => message, :destination => destination) + message["xSender"] = "forward-buffer" on_forward(message, destination) end Modified: lib/droonga/plugins/system/absorb_data.rb (+1 -0) =================================================================== --- lib/droonga/plugins/system/absorb_data.rb 2015-04-21 09:46:36 +0900 (3be7326) +++ lib/droonga/plugins/system/absorb_data.rb 2015-04-21 09:46:49 +0900 (f115f4a) @@ -69,6 +69,7 @@ module Droonga @dumper_error_message =****@dumpe*****(dump_options) do |message| begin message["dataset"] = current_dataset + message["xSender"] = "system.absorb-data" @messenger.forward(message, "to" => my_node_name, "type" => message["type"]) -------------- next part -------------- HTML����������������������������...Download