summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2012-09-25 17:08:48 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2012-09-25 17:08:48 +0000
commit4635ead8e8ff61dc5861e16476c16c75e7270240 (patch)
tree7d651f72e6e74ca3c92c0dd24802766ef0241d1e /java
parent3f291eb40a6a26993a0b729abe87b980b7711c34 (diff)
downloadqpid-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.java9
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;
}
}