Author: arnaudsimon
Date: Mon Oct 1 07:30:23 2007
New Revision: 580974
URL: http://svn.apache.org/viewvc?rev=580974&view=rev
Log:
Changed to use UUID for unique name generation
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=580974&r1=580973&r2=580974&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
Mon Oct 1 07:30:23 2007
@@ -38,6 +38,7 @@
import javax.jms.JMSException;
import javax.jms.Destination;
import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.UUID;
/**
* This is a 0.10 Session
@@ -367,7 +368,7 @@
if( amqd.getAMQQueueName() == null )
{
// generate a name for this queue
- amqd.setQueueName(new AMQShortString("tmp_"
+System.currentTimeMillis()));
+ amqd.setQueueName(new AMQShortString("TempQueue" +
UUID.randomUUID()));
}
getQpidSession().queueDeclare(amqd.getAMQQueueName().toString(), null,
null,
amqd.isAutoDelete() ? Option.AUTO_DELETE
: Option.NO_OPTION,
@@ -478,14 +479,9 @@
// Generate the queue name if the destination
indicates that a client generated name is to be used.
if (amqd.isNameRequired())
{
-
- //TODO this is for 0_10 only to be changed
- amqd.setQueueName(new AMQShortString("tmp_"
+System.currentTimeMillis()));
-
+ amqd.setQueueName(new
AMQShortString("TempQueue" + UUID.randomUUID()));
}
-
sendQueueDeclare(amqd,protocolHandler);
-
return amqd.getAMQQueueName();
}
}, _connection).execute();
