diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2012-09-25 17:08:48 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2012-09-25 17:08:48 +0000 |
| commit | ed98c069cc71dadad22279d49552bc62fb82b43c (patch) | |
| tree | cbaa7e4c95f627abe93546a314d336af85007aaa /qpid/java/client/src | |
| parent | 79c22ad9eb116acc84775d5c02698b6bfe5093ff (diff) | |
| download | qpid-python-ed98c069cc71dadad22279d49552bc62fb82b43c.tar.gz | |
QPID-4146 Applying patch attached by Pavel Moravec with modifications.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1389991 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index 16f464c496..e5f3e33d15 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java @@ -356,6 +356,13 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic for (Binding binding: bindings) { + // Currently there is a bug (QPID-3317) with setting up and tearing down x-bindings for link. + // The null check below is a way to side step that issue while fixing QPID-4146 + // Note this issue only affects producers. + if (binding.getQueue() == null && queueName == null) + { + continue; + } String queue = binding.getQueue() == null? queueName.asString(): binding.getQueue(); @@ -1237,6 +1244,8 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic { createSubscriptionQueue(dest,noLocal); } + sendQueueBind(dest.getAMQQueueName(), dest.getRoutingKey(), + null,dest.getExchangeName(),dest, false); break; } } |
