summaryrefslogtreecommitdiff
path: root/qpid/ruby/lib
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
commit7ad3988e599da508eb782ca84d97033b33692ac4 (patch)
treeb0447ad140b4fea947d324ff0b33e14b633a35a3 /qpid/ruby/lib
parent3531d11f4fe66237ea0f960228fabf995b88d6f6 (diff)
downloadqpid-python-7ad3988e599da508eb782ca84d97033b33692ac4.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@719245 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/ruby/lib')
-rw-r--r--qpid/ruby/lib/qpid/qmf.rb6
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/ruby/lib/qpid/qmf.rb b/qpid/ruby/lib/qpid/qmf.rb
index 2b7ab58e96..378d4068be 100644
--- a/qpid/ruby/lib/qpid/qmf.rb
+++ b/qpid/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