Author: ataylor Date: 2009-10-31 13:42:17 -0400 (Sat, 31 Oct 2009) New Revision: 8175 Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java Log: cluster test fix Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-10-31 08:05:49 UTC (rev 8174) +++ trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-10-31 17:42:17 UTC (rev 8175) @@ -1115,14 +1115,18 @@ Map<String, Object> params = generateParams(node, netty); - TransportConfiguration invmtc = new TransportConfiguration(INVM_ACCEPTOR_FACTORY, params); - configuration.getAcceptorConfigurations().add(invmtc); + if (netty) { TransportConfiguration nettytc = new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, params); configuration.getAcceptorConfigurations().add(nettytc); } + else + { + TransportConfiguration invmtc = new TransportConfiguration(INVM_ACCEPTOR_FACTORY, params); + configuration.getAcceptorConfigurations().add(invmtc); + } HornetQServer server;