summaryrefslogtreecommitdiff
path: root/java/broker
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2007-09-24 14:57:05 +0000
committerRobert Godfrey <rgodfrey@apache.org>2007-09-24 14:57:05 +0000
commit195ac3b5478f2d030b577298e963533d7e7da599 (patch)
tree50117b89b811c63c787c10496c7e8f2878e91159 /java/broker
parentd05128ec78839e652fc4ef8cdbbd60cb8e0a0129 (diff)
downloadqpid-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.java8
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)