Author: rajith
Date: Tue Sep 25 17:08:48 2012
New Revision: 1389991
URL: http://svn.apache.org/viewvc?rev=1389991&view=rev
Log:
QPID-4146 Applying patch attached by Pavel Moravec with modifications.
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=1389991&r1=1389990&r2=1389991&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
(original)
+++
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Tue Sep 25 17:08:48 2012
@@ -356,6 +356,13 @@ public class AMQSession_0_10 extends AMQ
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 AMQ
{
createSubscriptionQueue(dest,noLocal);
}
+ sendQueueBind(dest.getAMQQueueName(),
dest.getRoutingKey(),
+ null,dest.getExchangeName(),dest, false);
break;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
