[hornetq-commits] JBoss hornetq SVN: r9036 - trunk/src/main/org/hornetq/jms/server/impl.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-03-31 13:35:13 -0400 (Wed, 31 Mar 2010)
New Revision: 9036

Modified:
   trunk/src/main/org/hornetq/jms/server/impl/JMSServerManagerImpl.java
Log:
fix Queue deployment

* in JMSServerManagerImpl, call directly HornetQServer to deploy/destroy queues instead of going through the
  management interface

Modified: trunk/src/main/org/hornetq/jms/server/impl/JMSServerManagerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/jms/server/impl/JMSServerManagerImpl.java	2010-03-31 16:48:00 UTC (rev 9035)
+++ trunk/src/main/org/hornetq/jms/server/impl/JMSServerManagerImpl.java	2010-03-31 17:35:13 UTC (rev 9036)
@@ -624,7 +624,7 @@
 
       jmsManagementService.unregisterQueue(name);
 
-      server.getHornetQServerControl().destroyQueue(HornetQDestination.createQueueAddressFromName(name).toString());
+      server.destroyQueue(HornetQDestination.createQueueAddressFromName(name), null);
 
       storage.deleteDestination(PersistedType.Queue, name);
 
@@ -1111,10 +1111,11 @@
          // checks when routing messages to a topic that
          // does not exist - otherwise we would not be able to distinguish from a non existent topic and one with no
          // subscriptions - core has no notion of a topic
-         server.getHornetQServerControl().deployQueue(hqTopic.getAddress(),
-                                                      hqTopic.getAddress(),
-                                                      JMSServerManagerImpl.REJECT_FILTER,
-                                                      true);
+         server.deployQueue(SimpleString.toSimpleString(hqTopic.getAddress()),
+                            SimpleString.toSimpleString(hqTopic.getAddress()),
+                            SimpleString.toSimpleString(JMSServerManagerImpl.REJECT_FILTER),
+                            true,
+                            false);
 
          topics.put(topicName, hqTopic);