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;