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

[do-not-reply at jboss.org]

Author: borges
Date: 2011-06-28 11:19:24 -0400 (Tue, 28 Jun 2011)
New Revision: 10892

Modified:
   branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
Log:
HORNETQ-720 improve tests: Set identity as the nodeId is the same (for backup and live).

Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
===================================================================
--- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java	2011-06-28 15:18:21 UTC (rev 10891)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java	2011-06-28 15:19:24 UTC (rev 10892)
@@ -170,7 +170,7 @@
       config1.getAcceptorConfigurations().clear();
       config1.getAcceptorConfigurations().add(getAcceptorTransportConfiguration(false));
       TransportConfiguration tc = getConnectorTransportConfiguration(true);
-	config1.getConnectorConfigurations().put(LIVE_NODE_NAME, tc);
+      config1.getConnectorConfigurations().put(LIVE_NODE_NAME, tc);
 
       //liveConfig.setBackupConnectorName("toBackup");
       config1.setSecurityEnabled(false);
@@ -180,6 +180,7 @@
       backupConfig = config1;
 
       backupServer = createBackupServer();
+      backupServer.getServer().setIdentity("id_backup");
 
       Configuration config0 = super.createDefaultConfig();
       config0.getAcceptorConfigurations().clear();
@@ -189,6 +190,7 @@
       config0.setSharedStore(false);
       liveConfig = config0;
       liveServer = createLiveServer();
+      liveServer.getServer().setIdentity("id_live");
 
       liveServer.start();
       backupServer.start();