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,