Author: arnaudsimon
Date: Tue May 6 08:34:51 2008
New Revision: 653813
URL: http://svn.apache.org/viewvc?rev=653813&view=rev
Log:
QPID-1030: This solves the issue for the 0.10 code path
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=653813&r1=653812&r2=653813&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Tue May 6 08:34:51 2008
@@ -651,7 +651,13 @@
// Generate the queue name if the destination
indicates that a client generated name is to be used.
if (amqd.isNameRequired())
{
- amqd.setQueueName(new AMQShortString("TempQueue" +
UUID.randomUUID()));
+ String binddingKey = "";
+ for(AMQShortString key : amqd.getBindingKeys())
+ {
+ binddingKey = binddingKey + "_" +
key.toString();
+ }
+ amqd.setQueueName(new AMQShortString( binddingKey
+ "@"
+ + amqd.getExchangeName().toString() + "_"
+ UUID.randomUUID()));
}
return send0_10QueueDeclare(amqd, protocolHandler,
noLocal);
}
