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()),