[hornetq-commits] JBoss hornetq SVN: r9221 - trunk/src/main/org/hornetq/jms/client.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-05-10 17:31:57 -0400 (Mon, 10 May 2010)
New Revision: 9221

Modified:
   trunk/src/main/org/hornetq/jms/client/HornetQDestination.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-384 - Fixing a joram test

Modified: trunk/src/main/org/hornetq/jms/client/HornetQDestination.java
===================================================================
--- trunk/src/main/org/hornetq/jms/client/HornetQDestination.java	2010-05-10 21:13:40 UTC (rev 9220)
+++ trunk/src/main/org/hornetq/jms/client/HornetQDestination.java	2010-05-10 21:31:57 UTC (rev 9221)
@@ -48,8 +48,12 @@
    
    public static final String JMS_QUEUE_ADDRESS_PREFIX = "jms.queue.";
    
+   public static final String JMS_TEMP_QUEUE_ADDRESS_PREFIX = "jms.tempqueue.";
+   
    public static final String JMS_TOPIC_ADDRESS_PREFIX = "jms.topic.";
-   
+
+   public static final String JMS_TEMP_TOPIC_ADDRESS_PREFIX = "jms.temptopic.";
+
    private static final char SEPARATOR = '.';
       
    protected static String escape(final String input)
@@ -75,6 +79,18 @@
 
          return createTopic(name);
       }
+      else if (address.startsWith(HornetQTemporaryQueue.JMS_TEMP_QUEUE_ADDRESS_PREFIX))
+      {
+         String name = address.substring(HornetQTemporaryQueue.JMS_TEMP_QUEUE_ADDRESS_PREFIX.length());
+
+         return new HornetQTemporaryQueue(address, name, null);
+      }
+      else if (address.startsWith(HornetQTemporaryTopic.JMS_TEMP_TOPIC_ADDRESS_PREFIX))
+      {
+         String name = address.substring(HornetQTemporaryTopic.JMS_TEMP_TOPIC_ADDRESS_PREFIX.length());
+
+         return new HornetQTemporaryTopic(address, name, null);
+      }
       else
       {
          throw new IllegalArgumentException("Invalid address " + address);
@@ -158,14 +174,14 @@
    {
       String name = UUID.randomUUID().toString();
       
-      return new HornetQTemporaryQueue(JMS_QUEUE_ADDRESS_PREFIX.concat(name), name, session);
+      return new HornetQTemporaryQueue(JMS_TEMP_QUEUE_ADDRESS_PREFIX.concat(name), name, session);
    }
    
    public static HornetQTemporaryTopic createTemporaryTopic(final HornetQSession session)
    {
       String name = UUID.randomUUID().toString();
       
-      return new HornetQTemporaryTopic(JMS_TOPIC_ADDRESS_PREFIX.concat(name), name, session);
+      return new HornetQTemporaryTopic(JMS_TEMP_TOPIC_ADDRESS_PREFIX.concat(name), name, session);
    }