[Jboss-cvs] JBossAS SVN: r55998 - trunk/messaging/src/main/org/jboss/mq/server

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

Author: bdecoste
Date: 2006-08-16 14:13:12 -0400 (Wed, 16 Aug 2006)
New Revision: 55998

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

Modified: trunk/messaging/src/main/org/jboss/mq/server/JMSDestinationManager.java
===================================================================
--- trunk/messaging/src/main/org/jboss/mq/server/JMSDestinationManager.java	2006-08-16 18:12:38 UTC (rev 55997)
+++ trunk/messaging/src/main/org/jboss/mq/server/JMSDestinationManager.java	2006-08-16 18:13:12 UTC (rev 55998)
@@ -622,7 +622,33 @@
          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);
 
+      ClientConsumer ClientConsumer = null; //getClientConsumer(null);
+      JMSDestination queue = new JMSQueue(newQueue, ClientConsumer, this, parameters);
+      destinations.put(newQueue, queue);
+
+      return newQueue;
+   }
+   
+   public Topic createTopic(String topicName) throws JMSException
+   {
+      checkStopped();
+      
+      SpyTemporaryTopic topic = new SpyTemporaryTopic(topicName, null);
+
+      ClientConsumer ClientConsumer = getClientConsumer(null);
+      JMSDestination queue = new JMSTopic(topic, ClientConsumer, this, parameters);
+      destinations.put(topic, queue);
+
+      return topic;
+   }
+
    public void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) throws JMSException
    {
       checkStopped();