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);
Show replies by date