Author: jmesnil Date: 2010-08-24 04:37:37 -0400 (Tue, 24 Aug 2010) New Revision: 9584 Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/http/CoreClientOverHttpTest.java Log: fix CoreClientOverHttpTest Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/http/CoreClientOverHttpTest.java =================================================================== --- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/http/CoreClientOverHttpTest.java 2010-08-24 08:22:54 UTC (rev 9583) +++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/http/CoreClientOverHttpTest.java 2010-08-24 08:37:37 UTC (rev 9584) @@ -21,6 +21,8 @@ import org.hornetq.api.core.client.*; import org.hornetq.core.config.Configuration; import org.hornetq.core.config.impl.ConfigurationImpl; +import org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory; +import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; import org.hornetq.core.remoting.impl.netty.TransportConstants; import org.hornetq.core.server.HornetQServer; import org.hornetq.core.server.HornetQServers; @@ -42,13 +44,13 @@ HashMap<String, Object> params = new HashMap<String, Object>(); params.put(TransportConstants.HTTP_ENABLED_PROP_NAME, true); - conf.getAcceptorConfigurations().add(new TransportConfiguration(UnitTestCase.NETTY_ACCEPTOR_FACTORY, params)); + conf.getAcceptorConfigurations().add(new TransportConfiguration(NettyAcceptorFactory.class.getName(), params)); HornetQServer server = HornetQServers.newHornetQServer(conf, false); server.start(); - ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY, params)); + ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(NettyConnectorFactory.class.getName(), params)); ClientSessionFactory sf = locator.createSessionFactory(); ClientSession session = sf.createSession(false, true, true); @@ -98,15 +100,15 @@ HashMap<String, Object> params = new HashMap<String, Object>(); params.put(TransportConstants.HTTP_ENABLED_PROP_NAME, true); - conf.getAcceptorConfigurations().add(new TransportConfiguration(UnitTestCase.NETTY_ACCEPTOR_FACTORY, params)); + conf.getAcceptorConfigurations().add(new TransportConfiguration(NettyAcceptorFactory.class.getName(), params)); HornetQServer server = HornetQServers.newHornetQServer(conf, false); server.start(); - ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY, params)); + ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(NettyConnectorFactory.class.getName(), params)); + locator.setConnectionTTL(500); ClientSessionFactory sf = locator.createSessionFactory(); - sf.getServerLocator().setConnectionTTL(500); ClientSession session = sf.createSession(false, true, true);