From ed98c069cc71dadad22279d49552bc62fb82b43c Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Tue, 25 Sep 2012 17:08:48 +0000
Subject: 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
---
 .../src/main/java/org/apache/qpid/client/AMQSession_0_10.java    | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'qpid/java/client')

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;
                     }
                 }
-- 
cgit v1.2.1