[Jboss-cvs] JBossAS SVN: r56000 - branches/Branch_4_0/messaging/src/main/org/jboss/mq/server

[jboss-cvs-commits at lists.jboss.org]

Author: bdecoste
Date: 2006-08-16 14:37:19 -0400 (Wed, 16 Aug 2006)
New Revision: 56000

Modified:
   branches/Branch_4_0/messaging/src/main/org/jboss/mq/server/JMSDestinationManager.java
Log:
added createQueue(String) and createTopic(String) for E-EJB3

Modified: branches/Branch_4_0/messaging/src/main/org/jboss/mq/server/JMSDestinationManager.java
===================================================================
--- branches/Branch_4_0/messaging/src/main/org/jboss/mq/server/JMSDestinationManager.java	2006-08-16 18:36:28 UTC (rev 55999)
+++ branches/Branch_4_0/messaging/src/main/org/jboss/mq/server/JMSDestinationManager.java	2006-08-16 18:37:19 UTC (rev 56000)
@@ -622,7 +622,31 @@
          throw new JMSException("This destination does not exist !" + newTopic);
       return newTopic;
    }
+   
+   public Queue createQueue(String queueName) throws JMSException
+   {
+      checkStopped();
+      
+      SpyTemporaryQueue newQueue = new SpyTemporaryQueue(queueName, null);
 
+      JMSDestination queue = new JMSQueue(newQueue, null, this, parameters);
+      destinations.put(newQueue, queue);
+
+      return newQueue;
+   }
+   
+   public Topic createTopic(String topicName) throws JMSException
+   {
+      checkStopped();
+      
+      SpyTemporaryTopic topic = new SpyTemporaryTopic(topicName, null);
+
+      JMSDestination queue = new JMSTopic(topic, null, this, parameters);
+      destinations.put(topic, queue);
+
+      return topic;
+   }
+
    public void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) throws JMSException
    {
       checkStopped();