Author: rgodfrey
Date: Mon Sep 24 07:57:05 2007
New Revision: 578845
URL: http://svn.apache.org/viewvc?rev=578845&view=rev
Log:
QPID-612 : Use same scheme for every creation of temporary queue names
Removed:
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/client/protocol/AMQProtocolSessionTest.java
Modified:
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
Modified:
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java?rev=578845&r1=578844&r2=578845&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
(original)
+++
incubator/qpid/branches/M2.1/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
Mon Sep 24 07:57:05 2007
@@ -22,6 +22,7 @@
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 @@
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)
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java?rev=578845&r1=578844&r2=578845&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java
(original)
+++
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java
Mon Sep 24 07:57:05 2007
@@ -24,6 +24,7 @@
import javax.jms.JMSException;
import javax.jms.TemporaryTopic;
+import java.util.UUID;
/**
* AMQ implementation of TemporaryTopic.
@@ -38,7 +39,7 @@
*/
public AMQTemporaryTopic(AMQSession session)
{
- super(session.getTemporaryTopicExchangeName(),new
AMQShortString("TempQueue" + Long.toString(System.currentTimeMillis())));
+ super(session.getTemporaryTopicExchangeName(),new
AMQShortString("tmp_" + UUID.randomUUID()));
_session = session;
}
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java?rev=578845&r1=578844&r2=578845&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
(original)
+++
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
Mon Sep 24 07:57:05 2007
@@ -53,6 +53,7 @@
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
+import java.util.UUID;
/**
* Wrapper for protocol session that provides type-safe access to session
attributes. <p/> The underlying protocol
@@ -411,14 +412,8 @@
protected AMQShortString generateQueueName()
{
int id;
- synchronized (_queueIdLock)
- {
- id = _queueId++;
- }
- // get rid of / and : and ; from address for spec conformance
- String localAddress =
StringUtils.replaceChars(_minaProtocolSession.getLocalAddress().toString(),
"/;:", "");
- return new AMQShortString("tmp_" + localAddress + "_" + id);
+ return new AMQShortString("tmp_" + UUID.randomUUID());
}
/** @param delay delay in seconds (not ms) */
