[hornetq-commits] JBoss hornetq SVN: r10304 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2011-03-08 02:45:20 -0500 (Tue, 08 Mar 2011)
New Revision: 10304

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java
Log:
fixed cluster connection test

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java	2011-03-08 02:19:56 UTC (rev 10303)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java	2011-03-08 07:45:20 UTC (rev 10304)
@@ -114,6 +114,8 @@
 
       Map<String, Object> acceptorParams_1 = new HashMap<String, Object>();
       acceptorParams_1.put(TransportConstants.PORT_PROP_NAME, port_1);
+      TransportConfiguration acceptorConfig_0 = new TransportConfiguration(NettyAcceptorFactory.class.getName());
+
       TransportConfiguration acceptorConfig_1 = new TransportConfiguration(NettyAcceptorFactory.class.getName(),
                                                                            acceptorParams_1);
 
@@ -129,7 +131,7 @@
 
       clusterConnectionConfig_0 = new ClusterConnectionConfiguration(clusterName,
                                                                      queueConfig.getAddress(),
-                                                                     clusterName,
+                                                                     "netty",
                                                                      1000,
                                                                      false,
                                                                      false,
@@ -156,17 +158,18 @@
       conf_1.setSecurityEnabled(false);
       conf_1.setJMXManagementEnabled(true);
       conf_1.setClustered(true);
+      conf_1.getClusterConfigurations().add(clusterConnectionConfig_0);
       conf_1.getAcceptorConfigurations().add(acceptorConfig_1);
       conf_1.getConnectorConfigurations().put("netty", connectorConfig_1);
       conf_1.getQueueConfigurations().add(queueConfig);
       conf_1.getDiscoveryGroupConfigurations().put(discoveryName, discoveryGroupConfig);
       conf_1.getBroadcastGroupConfigurations().add(broadcastGroupConfig);
 
-      Configuration conf_0 = createBasicConfig();
+      Configuration conf_0 = createBasicConfig(1);
       conf_0.setSecurityEnabled(false);
       conf_0.setJMXManagementEnabled(true);
       conf_0.setClustered(true);
-      conf_0.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));
+      conf_0.getAcceptorConfigurations().add(acceptorConfig_0);
       conf_0.getConnectorConfigurations().put("netty", connectorConfig_0);
       conf_0.getClusterConfigurations().add(clusterConnectionConfig_0);
       conf_0.getDiscoveryGroupConfigurations().put(discoveryName, discoveryGroupConfig);