Author: jmesnil Date: 2009-11-09 04:46:10 -0500 (Mon, 09 Nov 2009) New Revision: 8251 Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java Log: fixed cluster tests setup * use the correct transport config params for invm acceptor/connector Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-08 04:14:55 UTC (rev 8250) +++ trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-09 09:46:10 UTC (rev 8251) @@ -1267,18 +1267,17 @@ 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); + } - TransportConfiguration invmtc_c = new TransportConfiguration(INVM_CONNECTOR_FACTORY, params); - configuration.getConnectorConfigurations().put(invmtc_c.getName(), invmtc_c); - List<Pair<String, String>> connectorPairs = new ArrayList<Pair<String, String>>(); if (netty) @@ -1291,6 +1290,9 @@ } else { + TransportConfiguration invmtc_c = new TransportConfiguration(INVM_CONNECTOR_FACTORY, params); + configuration.getConnectorConfigurations().put(invmtc_c.getName(), invmtc_c); + connectorPairs.add(new Pair<String, String>(invmtc_c.getName(), invmBackuptc == null ? null : invmBackuptc.getName())); }