[hornetq-commits] JBoss hornetq SVN: r9033 - in trunk: tests/src/org/hornetq/tests/integration/jms and 1 other directory.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-03-31 12:04:11 -0400 (Wed, 31 Mar 2010)
New Revision: 9033

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

* in JMSServerManagerImpl.internalCreateQueue, call directly HornetQServer.deployQueue() instead of going throuhg 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 14:55:21 UTC (rev 9032)
+++ trunk/src/main/org/hornetq/jms/server/impl/JMSServerManagerImpl.java	2010-03-31 16:04:11 UTC (rev 9033)
@@ -1076,11 +1076,11 @@
             coreFilterString = SelectorTranslator.convertToHornetQFilterString(selectorString);
          }
 
-         server.getHornetQServerControl().deployQueue(hqQueue.getAddress(),
-                                                      hqQueue.getAddress(),
-                                                      coreFilterString,
-                                                      durable);
-
+         server.deployQueue(SimpleString.toSimpleString(hqQueue.getAddress()),
+                            SimpleString.toSimpleString(hqQueue.getAddress()),
+                            SimpleString.toSimpleString(coreFilterString),
+                            durable,
+                            false);
          queues.put(queueName, hqQueue);
 
          jmsManagementService.registerQueue(hqQueue);

Modified: trunk/tests/src/org/hornetq/tests/integration/jms/ManualReconnectionToSingleServerTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/jms/ManualReconnectionToSingleServerTest.java	2010-03-31 14:55:21 UTC (rev 9032)
+++ trunk/tests/src/org/hornetq/tests/integration/jms/ManualReconnectionToSingleServerTest.java	2010-03-31 16:04:11 UTC (rev 9033)
@@ -164,7 +164,7 @@
       JMSConfiguration configuration = new JMSConfigurationImpl();
       context = new InVMContext();
       configuration.setContext(context);
-      configuration.getQueueConfigurations().add(new JMSQueueConfigurationImpl(queueName, null, false, queueName));
+      configuration.getQueueConfigurations().add(new JMSQueueConfigurationImpl(queueName, null, true, queueName));
 
       ConnectionFactoryConfiguration cfConfig = new ConnectionFactoryConfigurationImpl("cf",
                                                                                        new TransportConfiguration(NettyConnectorFactory.class.getName()),