Navigation Menu

Skip to content

Commit

Permalink
Fix missing path
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Jan 6, 2015
1 parent a868fec commit 498f7ef
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions lib/droonga/dispatcher.rb
Expand Up @@ -116,7 +116,7 @@ def process_message(message)
def forward(message, destination)
logger.trace("forward start")
unless local?(destination)
return if @cluster.forward(message, destination)
return if @engine_state.cluster.forward(message, destination)
end
@forwarder.forward(message, destination)
logger.trace("forward done")
Expand Down Expand Up @@ -187,7 +187,7 @@ def dispatch(message, destination)
"type" => "dispatcher",
"to" => destination,
}
@cluster.forward(forward_message, forward_destination) ||
@engine_state.cluster.forward(forward_message, forward_destination) ||
@forwarder.forward(forward_message, forward_destination)
end
end
Expand Down

0 comments on commit 498f7ef

Please sign in to comment.