summaryrefslogtreecommitdiff
path: root/ruby
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2008-11-20 14:51:45 +0000
committerTed Ross <tross@apache.org>2008-11-20 14:51:45 +0000
commitbe6a6d0014e60226607fdc8d7e5d67bd1eb13b4f (patch)
treef24d5b3257ccc1ae8902fa9af5d7ed1d1612bf30 /ruby
parent57de045575c5004f04f84450c2296a3093dc8b2d (diff)
downloadqpid-python-be6a6d0014e60226607fdc8d7e5d67bd1eb13b4f.tar.gz
QPID-1476 - routing keys used for updates can't be used to discriminate by agent
- Fixed routing keys in agents and binding keys in consoles - Added some additional debug output for ManagementAgentImpl - Minor cleanup in the connection close path for ManagementAgentImpl git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@719245 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'ruby')
-rw-r--r--ruby/lib/qpid/qmf.rb6
1 files changed, 3 insertions, 3 deletions
diff --git a/ruby/lib/qpid/qmf.rb b/ruby/lib/qpid/qmf.rb
index 2b7ab58e96..378d4068be 100644
--- a/ruby/lib/qpid/qmf.rb
+++ b/ruby/lib/qpid/qmf.rb
@@ -217,7 +217,7 @@ module Qpid::Qmf
@brokers.each do |broker|
args = { :exchange => "qpid.management",
:queue => broker.topicName,
- :binding_key => "console.obj.#{package_name}.#" }
+ :binding_key => "console.obj.*.*.#{package_name}.#" }
broker.amqpSession.exchange_bind(args)
end
end
@@ -230,7 +230,7 @@ module Qpid::Qmf
@brokers.each do |broker|
args = { :exchange => "qpid.management",
:queue => broker.topicName,
- :binding_key => "console.obj.#{pname}.#{cname}.#" }
+ :binding_key => "console.obj.*.*.#{pname}.#{cname}.#" }
broker.amqpSession.exchange_bind(args)
end
end
@@ -637,7 +637,7 @@ module Qpid::Qmf
if @rcv_objects && ! @user_bindings
key_list << "console.obj.#"
else
- key_list << "console.obj.org.apache.qpid.broker.agent"
+ key_list << "console.obj.*.*.org.apache.qpid.broker.agent"
end
key_list << "console.event.#" if @rcv_events
key_list << "console.heartbeat.#" if @rcv_heartbeats