diff options
| author | Ted Ross <tross@apache.org> | 2009-06-19 20:34:11 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2009-06-19 20:34:11 +0000 |
| commit | 20f74c4f37b906ac1654fded3b099ed74b3a6490 (patch) | |
| tree | c4e136dce1e245593e85728547f2755d9a7abfde /java/management | |
| parent | 0e4711571f523869472fea0cfc04be737ef31bf7 (diff) | |
| download | qpid-python-20f74c4f37b906ac1654fded3b099ed74b3a6490.tar.gz | |
QPID-1919 - Bugfix patch from Bryan Kearney
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@786657 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/management')
| -rw-r--r-- | java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java b/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java index 80348c52d9..823bda7dca 100644 --- a/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java +++ b/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) { |