Navigation Menu

Skip to content

Commit

Permalink
Send dumped messages to the current dataset correctly
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 14, 2015
1 parent 0ac9983 commit f1cd9ff
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions lib/droonga/plugins/system/absorb_data.rb
Expand Up @@ -63,6 +63,7 @@ def handle
begin
@total_n_source_records = count_total_n_source_records
dumper_error_message = dumper.run do |message|
message["dataset"] = current_dataset
@messenger.forward(message,
"to" => my_node_name,
"type" => message["type"])
Expand Down Expand Up @@ -141,6 +142,10 @@ def my_node_name
ENV["DROONGA_ENGINE_NAME"]
end

def current_dataset
@request.dataset
end

def prepare_progress_interval_seconds
interval_seconds = @request.request["progressIntervalSeconds"] ||
DEFAULT_PROGRESS_INTERVAL_SECONDS
Expand Down

0 comments on commit f1cd9ff

Please sign in to comment.