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 | 4635ead8e8ff61dc5861e16476c16c75e7270240 (patch) | |
| tree | 7d651f72e6e74ca3c92c0dd24802766ef0241d1e /java | |
| parent | 3f291eb40a6a26993a0b729abe87b980b7711c34 (diff) | |
| download | qpid-python-4635ead8e8ff61dc5861e16476c16c75e7270240.tar.gz | |
QPID-4146 Applying patch attached by Pavel Moravec with modifications.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1389991 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index 16f464c496..e5f3e33d15 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/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; } } |
