From 95ffd04aa91e6af9cd7eef45a6e724b6559027db Mon Sep 17 00:00:00 2001 From: Ted Ross Date: Fri, 19 Jun 2009 20:34:11 +0000 Subject: QPID-1919 - Bugfix patch from Bryan Kearney git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@786657 13f79535-47bb-0310-9956-ffa450edef68 --- .../management/agent/src/main/java/org/apache/qpid/agent/Agent.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java b/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java index 80348c52d9..823bda7dca 100644 --- a/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java +++ b/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java @@ -149,7 +149,7 @@ public class Agent implements MessageListener { session = connection.createSession(sessionTransacted, acknowledgeMode); - reply = session.createQueue("direct://amq.direct//" + label); + reply = session.createQueue(String.format("direct://amq.direct//%s-%s?exclusive='True'&autodelete='True'",label,systemId)); cons = session.createConsumer(reply); cons.setMessageListener(this); prod = session.createProducer(null); @@ -291,8 +291,8 @@ public class Agent implements MessageListener .createConsumer(session .createQueue(String .format( - "management://qpid.management//%s?routingkey='agent.%d.%d'", - label, bbank, abank))); + "management://qpid.management//%s-%s?routingkey='agent.%d.%d'&exclusive='True'&autodelete='True'", + label, systemId, bbank, abank))); mc.setMessageListener(this); } catch (JMSException e) { -- cgit v1.2.1