diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2007-09-24 14:57:05 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2007-09-24 14:57:05 +0000 |
| commit | 195ac3b5478f2d030b577298e963533d7e7da599 (patch) | |
| tree | 50117b89b811c63c787c10496c7e8f2878e91159 /java/broker | |
| parent | d05128ec78839e652fc4ef8cdbbd60cb8e0a0129 (diff) | |
| download | qpid-python-195ac3b5478f2d030b577298e963533d7e7da599.tar.gz | |
QPID-612 : Use same scheme for every creation of temporary queue names
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@578845 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java index 2bc185cfb4..29697542be 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java +++ b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java @@ -22,6 +22,7 @@ package org.apache.qpid.server.handler; import java.text.MessageFormat; import java.util.concurrent.atomic.AtomicInteger; +import java.util.UUID; import org.apache.log4j.Logger; import org.apache.qpid.AMQException; @@ -158,12 +159,7 @@ public class QueueDeclareHandler implements StateAwareMethodListener<QueueDeclar protected AMQShortString createName() { - return new AMQShortString("tmp_" + pad(_counter.incrementAndGet())); - } - - protected static String pad(int value) - { - return MessageFormat.format("{0,number,0000000000000}", value); + return new AMQShortString("tmp_" + UUID.randomUUID()); } protected AMQQueue createQueue(QueueDeclareBody body, VirtualHost virtualHost, final AMQProtocolSession session) |
