Permalink
Browse files

changing some queue names in the mapper to be more readble in the out…

…put of

scripts/rabbitmqctl list_bindings -p /nanite
  • Loading branch information...
1 parent b082a87 commit 1b2a612512427cb9dc9d0abc9c3c30788239c87e Ezra Zygmuntowicz committed Feb 1, 2009
Showing with 5 additions and 5 deletions.
  1. +3 −3 lib/nanite/actor.rb
  2. +2 −2 lib/nanite/mapper.rb
View
@@ -19,6 +19,6 @@ def self.provides_for(prefix)
sets << "/#{prefix}/#{meth}".squeeze('/')
end
sets
- end # def
- end # class
-end # module
+ end
+ end
+end
View
@@ -191,11 +191,11 @@ def push(type, payload="", opts = {:selector => :least_loaded, :timeout => 60})
def setup_queues
agent.log.debug "setting up queues"
- amq.queue("heartbeat#{@identity}", :exclusive => true).bind(amq.fanout('heartbeat')).subscribe{ |ping|
+ amq.queue("heartbeat-#{agent.identity}", :exclusive => true).bind(amq.fanout('heartbeat')).subscribe{ |ping|
agent.log.debug "Got heartbeat"
handle_ping(agent.load_packet(ping))
}
- amq.queue("mapper#{@identity}", :exclusive => true).bind(amq.fanout('registration')).subscribe{ |msg|
+ amq.queue("registration-#{agent.identity}", :exclusive => true).bind(amq.fanout('registration')).subscribe{ |msg|
agent.log.debug "Got registration"
register(agent.load_packet(msg))
}

0 comments on commit 1b2a612

Please sign in to comment.