Navigation Menu

Skip to content

Commit

Permalink
Use Address instead of custom parser
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 30, 2015
1 parent 6a1b98c commit d4464b4
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion lib/droonga/cluster.rb
Expand Up @@ -17,6 +17,7 @@
require "droonga/changable"
require "droonga/path"
require "droonga/file_observer"
require "droonga/address"
require "droonga/engine_node"
require "droonga/differ"

Expand Down Expand Up @@ -161,7 +162,7 @@ def engine_nodes_status

def forward(message, destination)
receiver = destination["to"]
receiver_node_name = receiver.match(/\A[^:]+:\d+\/[^.]+/).to_s
receiver_node_name = Address.parse(receiver).node
raise NotStartedYet.new unless @engine_nodes
@engine_nodes.each do |node|
if node.name == receiver_node_name
Expand Down

0 comments on commit d4464b4

Please sign in to comment.