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)