[hornetq-commits] JBoss hornetq SVN: r11027 - branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-07-22 10:00:06 -0400 (Fri, 22 Jul 2011)
New Revision: 11027

Modified:
   branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
Add consistency check

Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-07-22 13:59:26 UTC (rev 11026)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-07-22 14:00:06 UTC (rev 11027)
@@ -1881,8 +1881,9 @@
       }
 
       TransportConfiguration connectorConfig = createTransportConfiguration(netty, false, generateParams(node, netty));
-      server.getConfiguration().getConnectorConfigurations().put(name, connectorConfig);
-      
+      Configuration config = server.getConfiguration();
+      config.getConnectorConfigurations().put(name, connectorConfig);
+      assertEquals(config.isBackup(), node > 2);
       ClusterConnectionConfiguration clusterConf = new ClusterConnectionConfiguration(name,
                                                                                       address,
                                                                                       name,