[hornetq-commits] JBoss hornetq SVN: r10984 - branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-07-14 12:24:00 -0400 (Thu, 14 Jul 2011)
New Revision: 10984

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
improving log on test

Modified: branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-07-14 05:57:39 UTC (rev 10983)
+++ branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-07-14 16:24:00 UTC (rev 10984)
@@ -1303,7 +1303,7 @@
    {
       if (sfs[node] != null)
       {
-         throw new IllegalArgumentException("Already a server at " + node);
+         throw new IllegalArgumentException("Already a factory at " + node);
       }
 
       Map<String, Object> params = generateParams(node, netty);
@@ -1332,6 +1332,7 @@
       locators[node].setBlockOnDurableSend(true);
       ClientSessionFactory sf = locators[node].createSessionFactory();
 
+      sf.createSession().close();
       sfs[node] = sf;
    }
 
@@ -1482,6 +1483,8 @@
                server = HornetQServers.newHornetQServer(configuration, false);
             }
          }
+         
+         server.setIdentity(this.getClass().getSimpleName() + "/Live(" + node + ")");
          servers[node] = server;
       }
 
@@ -1557,6 +1560,7 @@
             server = HornetQServers.newHornetQServer(configuration, false);
          }
       }
+      server.setIdentity(this.getClass().getSimpleName() + "/Backup(" + node + " of live " + liveNode + ")");
       servers[node] = server;
    }