Author: rajith
Date: Thu Jan 26 14:43:20 2012
New Revision: 1236198
URL: http://svn.apache.org/viewvc?rev=1236198&view=rev
Log:
QPID-3265 This is not a fix for this issue, but rather a minor step towards it.
It's incorrect to add the binding for the temp queue to the bindings object as
if the destination is used with another consumer it will interfere.
Therefore the qeueu bind is sent explictly.
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=1236198&r1=1236197&r2=1236198&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
Thu Jan 26 14:43:20 2012
@@ -1299,10 +1299,10 @@ public class AMQSession_0_10 extends AMQ
node.setExclusive(true);
node.setAutoDelete(!node.isDurable());
send0_10QueueDeclare(dest,null,false,true);
- node.addBinding(new Binding(dest.getAddressName(),
- dest.getQueueName(),// should have one by
now
- dest.getSubject(),
- Collections.<String,Object>emptyMap()));
+ getQpidSession().exchangeBind(dest.getQueueName(),
+ dest.getAddressName(),
+ dest.getSubject(),
+ Collections.<String,Object>emptyMap());
sendQueueBind(dest.getAMQQueueName(), dest.getRoutingKey(),
null,dest.getExchangeName(),dest, false);
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
