summaryrefslogtreecommitdiff
path: root/qpid/java/client/src
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
commited98c069cc71dadad22279d49552bc62fb82b43c (patch)
treecbaa7e4c95f627abe93546a314d336af85007aaa /qpid/java/client/src
parent79c22ad9eb116acc84775d5c02698b6bfe5093ff (diff)
downloadqpid-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.java9
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;
}
}