lib/pushyd/endpoint.rb in pushyd-0.3.3 vs lib/pushyd/endpoint.rb in pushyd-0.3.4

- old
+ new

@@ -98,10 +98,10 @@ def channel_subscribe rule # Check information rule_name = rule[:name].to_s rule_topic = rule[:topic].to_s rule_routes = rule[:routes].to_s.split(' ') - rule_queue = "#{Conf.name}-#{PROXY_SCOPE}-#{rule[:name]}" + rule_queue = "#{Conf.name}-#{rule[:name]}" fail PushyDaemon::EndpointSubscribeContext, "rule [#{rule_name}] lacking topic" unless rule_topic fail PushyDaemon::EndpointSubscribeContext, "rule [#{rule_name}] lacking routes" if rule_routes.empty? # Create queue for this rule (remove it beforehand) #conn.create_channel.queue_delete(rule_queue_name)