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 | 95ffd04aa91e6af9cd7eef45a6e724b6559027db (patch) | |
| tree | fcce2edf66d5e3695728fbce716ece2aa0e9c1d5 | |
| parent | 6587e4ae777224625c6d8371f626e6486da16f72 (diff) | |
| download | qpid-python-95ffd04aa91e6af9cd7eef45a6e724b6559027db.tar.gz | |
QPID-1919 - Bugfix patch from Bryan Kearney
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@786657 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java | 6 |
1 files changed, 3 insertions, 3 deletions
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) { |