diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-01 14:30:23 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-01 14:30:23 +0000 |
| commit | e12d214f29a42c81735c514f87c3b9857aa40360 (patch) | |
| tree | c078e9f46fe9971abd1936fe932ec61388e4348f | |
| parent | 8d8dc36fb664cf94c33b092550f22a40d4c92184 (diff) | |
| download | qpid-python-e12d214f29a42c81735c514f87c3b9857aa40360.tar.gz | |
Changed to use UUID for unique name generation
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@580974 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 10 |
1 files changed, 3 insertions, 7 deletions
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 cdc74f62c8..984acceb65 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 @@ -38,6 +38,7 @@ import org.slf4j.LoggerFactory; 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 @@ public class AMQSession_0_10 extends AMQSession 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 @@ public class AMQSession_0_10 extends AMQSession // 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(); |