Navigation Menu

Skip to content

Commit

Permalink
Set "xSender" field for some special cases, to track messages
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 21, 2015
1 parent 9d67663 commit b51a8f7
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
1 change: 1 addition & 0 deletions lib/droonga/forward_buffer.rb
Expand Up @@ -107,6 +107,7 @@ def forward(buffered_message_path)
logger.trace("forward: Forwarding buffered message",
:message => message,
:destination => destination)
message["xSender"] = "forward-buffer"
on_forward(message, destination)
end

Expand Down
1 change: 1 addition & 0 deletions lib/droonga/plugins/system/absorb_data.rb
Expand Up @@ -69,6 +69,7 @@ def start
@dumper_error_message = @dumper.run(dump_options) do |message|
begin
message["dataset"] = current_dataset
message["xSender"] = "system.absorb-data"
@messenger.forward(message,
"to" => my_node_name,
"type" => message["type"])
Expand Down

0 comments on commit b51a8f7

Please sign in to comment.