[hornetq-commits] JBoss hornetq SVN: r8251 - trunk/tests/src/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

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()));
       }