diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-01-08 13:44:01 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-01-08 13:44:01 +0000 |
| commit | 5d6a13afe68d81a8f94e9b5fd59eaa3f1cd8b35b (patch) | |
| tree | 4960e755fd9d2d4b7e42bcfcc7d1314c24ae6a61 /java/client | |
| parent | 0129e12deaabcf3cf3be23913967397be6a12e3a (diff) | |
| download | qpid-python-5d6a13afe68d81a8f94e9b5fd59eaa3f1cd8b35b.tar.gz | |
QPID-1644 : Fix 0-8 Java Client to only declare amq.* exchanges passively when creating a producer
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1228843 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java | 21 |
1 files changed, 12 insertions, 9 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java index 34d2ade723..b2f998cb2c 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java @@ -40,6 +40,7 @@ import org.apache.qpid.framing.CompositeAMQDataBlock; import org.apache.qpid.framing.ContentBody; import org.apache.qpid.framing.ContentHeaderBody; import org.apache.qpid.framing.ExchangeDeclareBody; +import org.apache.qpid.framing.MethodRegistry; public class BasicMessageProducer_0_8 extends BasicMessageProducer { @@ -53,15 +54,17 @@ public class BasicMessageProducer_0_8 extends BasicMessageProducer void declareDestination(AMQDestination destination) { - ExchangeDeclareBody body = getSession().getMethodRegistry().createExchangeDeclareBody(_session.getTicket(), - destination.getExchangeName(), - destination.getExchangeClass(), - false, - false, - false, - false, - true, - null); + final MethodRegistry methodRegistry = getSession().getMethodRegistry(); + ExchangeDeclareBody body = + methodRegistry.createExchangeDeclareBody(_session.getTicket(), + destination.getExchangeName(), + destination.getExchangeClass(), + destination.getExchangeName().toString().startsWith("amq."), + false, + false, + false, + true, + null); // Declare the exchange // Note that the durable and internal arguments are ignored since passive is set to false |