# File lib/redis/distributed.rb, line 606 def subscribe(channel, *channels, &block) if channels.empty? @subscribed_node = node_for(channel) @subscribed_node.subscribe(channel, &block) else ensure_same_node(:subscribe, channel, *channels) do |node| @subscribed_node = node node.subscribe(channel, *channels, &block) end end end