[jboss-cvs] JBoss Messaging SVN: r1715 - branches/Branch_Client_Failover_Experiment/tests/src/org/jboss/test/messaging/jms/clustering

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2006-12-06 22:20:14 -0500 (Wed, 06 Dec 2006)
New Revision: 1715

Modified:
   branches/Branch_Client_Failover_Experiment/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java
Log:
placing back a test

Modified: branches/Branch_Client_Failover_Experiment/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java
===================================================================
--- branches/Branch_Client_Failover_Experiment/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java	2006-12-07 03:17:47 UTC (rev 1714)
+++ branches/Branch_Client_Failover_Experiment/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java	2006-12-07 03:20:14 UTC (rev 1715)
@@ -65,54 +65,54 @@
 
    // Public --------------------------------------------------------
 
-//   public void testConnectionFactoryConnect() throws Exception
-//   {
-//      try
-//      {
-//         JBossConnectionFactory factory =  (JBossConnectionFactory )ic1.lookup("/ConnectionFactory");
-//         ClusteredClientConnectionFactoryDelegate delegate =
-//                      (ClusteredClientConnectionFactoryDelegate)factory.getDelegate();
-//         log.info ("number of delegates = " + delegate.getDelegates().length);
-//         log.info ("number of servers = " + ServerManagement.getServer(0).getNumberOfNodesOnCluster());
-//
-//         delegate.init();
-//
-//         for (int i = 0; i < 3; i++)
-//         {
-//            int failNode = delegate.getDelegates()[0].getFailoverNode(i);
-//            log.info("Failover node for server" + i + " = " + failNode);
-//            log.info("InvokerLocator for server " + i + " = " + delegate.getDelegates()[i].getServerLocatorURI());
-//
-//            assertEquals("Server1 should have the same failoverMapping",
-//                         failNode, delegate.getDelegates()[1].getFailoverNode(i));
-//            assertEquals("Server2 should have the same failoverMapping",
-//                         failNode, delegate.getDelegates()[2].getFailoverNode(i));
-//         }
-//
-//         assertEquals(3, ServerManagement.getServer(0).getNumberOfNodesOnCluster());
-//         assertEquals(3, delegate.getDelegates().length);
-//
-//
-//         ServerManagement.log(ServerManagement.INFO,"Stopping server 2 as part of testConnectionFactoryConnect");
-//         ServerManagement.stop(2,true);
-//
-//         ServerManagement.log(ServerManagement.INFO,"##### Looking up ConnectionFactory at testConnectionFactoryConnect");
-//
-//         factory =  (JBossConnectionFactory )ic1.lookup("/ConnectionFactory");
-//         delegate = (ClusteredClientConnectionFactoryDelegate)factory.getDelegate();
-//
-//         assertEquals(2, ServerManagement.getServer(0).getNumberOfNodesOnCluster());
-//         assertEquals(2, delegate.getDelegates().length);
-//      }
-//      finally
-//      {
-//         ServerManagement.start("all", 2);
-//      }
-//
-//
-//   }
+   public void testConnectionFactoryConnect() throws Exception
+   {
+      try
+      {
+         JBossConnectionFactory factory =  (JBossConnectionFactory )ic1.lookup("/ConnectionFactory");
+         ClusteredClientConnectionFactoryDelegate delegate =
+                      (ClusteredClientConnectionFactoryDelegate)factory.getDelegate();
+         log.info ("number of delegates = " + delegate.getDelegates().length);
+         log.info ("number of servers = " + ServerManagement.getServer(0).getNumberOfNodesOnCluster());
 
+         delegate.init();
 
+         for (int i = 0; i < 3; i++)
+         {
+            int failNode = delegate.getDelegates()[0].getFailoverNode(i);
+            log.info("Failover node for server" + i + " = " + failNode);
+            log.info("InvokerLocator for server " + i + " = " + delegate.getDelegates()[i].getServerLocatorURI());
+
+            assertEquals("Server1 should have the same failoverMapping",
+                         failNode, delegate.getDelegates()[1].getFailoverNode(i));
+            assertEquals("Server2 should have the same failoverMapping",
+                         failNode, delegate.getDelegates()[2].getFailoverNode(i));
+         }
+
+         assertEquals(3, ServerManagement.getServer(0).getNumberOfNodesOnCluster());
+         assertEquals(3, delegate.getDelegates().length);
+
+
+         ServerManagement.log(ServerManagement.INFO,"Stopping server 2 as part of testConnectionFactoryConnect");
+         ServerManagement.stop(2,true);
+
+         ServerManagement.log(ServerManagement.INFO,"##### Looking up ConnectionFactory at testConnectionFactoryConnect");
+
+         factory =  (JBossConnectionFactory )ic1.lookup("/ConnectionFactory");
+         delegate = (ClusteredClientConnectionFactoryDelegate)factory.getDelegate();
+
+         assertEquals(2, ServerManagement.getServer(0).getNumberOfNodesOnCluster());
+         assertEquals(2, delegate.getDelegates().length);
+      }
+      finally
+      {
+         ServerManagement.start("all", 2);
+      }
+
+
+   }
+
+
    public void testTopicSubscriber() throws Exception
    {
       try