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 | 4dac7009ffa59199a16efc44864205aaabf2d0c1 (patch) | |
| tree | 6e85b61b738a201b07e6ec348a7b5f783a494c34 /java/client/src | |
| parent | a52c001a37f1f301d9346047cf3216298bcdb635 (diff) | |
| download | qpid-python-4dac7009ffa59199a16efc44864205aaabf2d0c1.tar.gz | |
Changed to use UUID for unique name generation
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@580974 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index cdc74f62c8..984acceb65 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/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(); |