You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by db...@apache.org on 2008/09/25 03:53:09 UTC

svn commit: r698797 - /openejb/trunk/openejb3/server/openejb-ejbd/src/test/java/org/apache/openejb/server/ejbd/FailoverTest.java

Author: dblevins
Date: Wed Sep 24 18:53:09 2008
New Revision: 698797

URL: http://svn.apache.org/viewvc?rev=698797&view=rev
Log:
Beefed up the failover test so that it tests a total failure followed by a server being available.

Modified:
    openejb/trunk/openejb3/server/openejb-ejbd/src/test/java/org/apache/openejb/server/ejbd/FailoverTest.java

Modified: openejb/trunk/openejb3/server/openejb-ejbd/src/test/java/org/apache/openejb/server/ejbd/FailoverTest.java
URL: http://svn.apache.org/viewvc/openejb/trunk/openejb3/server/openejb-ejbd/src/test/java/org/apache/openejb/server/ejbd/FailoverTest.java?rev=698797&r1=698796&r2=698797&view=diff
==============================================================================
--- openejb/trunk/openejb3/server/openejb-ejbd/src/test/java/org/apache/openejb/server/ejbd/FailoverTest.java (original)
+++ openejb/trunk/openejb3/server/openejb-ejbd/src/test/java/org/apache/openejb/server/ejbd/FailoverTest.java Wed Sep 24 18:53:09 2008
@@ -33,6 +33,7 @@
 import org.apache.openejb.server.ServiceException;
 
 import javax.ejb.Remote;
+import javax.ejb.EJBException;
 import javax.naming.Context;
 import javax.naming.InitialContext;
 import javax.naming.NamingException;
@@ -95,6 +96,18 @@
         assertEquals(Host.GREEN, target.getHost());
 
         green.stop();
+
+        try {
+            target.getHost();
+            fail("EJBException should have been thrown");
+        } catch (EJBException e) {
+            // pass
+        }
+
+        red.start();
+
+        assertEquals(Host.RED, target.getHost());
+
     }
 
     public void testCrash() throws Exception {
@@ -109,7 +122,6 @@
         } catch (Exception e) {
         }
         Assembler assembler = SystemInstance.get().getComponent(Assembler.class);
-//        Assembler assembler = new Assembler();
         ConfigurationFactory config = new ConfigurationFactory();
 
         EjbJar ejbJar = new EjbJar();
@@ -131,6 +143,21 @@
         assertEquals(Host.GREEN, target.kill(Host.RED, Host.BLUE).host);
         assertEquals(Host.GREEN, target.getHost());
 
+        red.stop();
+        blue.stop();
+        green.stop();
+
+        try {
+            target.getHost();
+            fail("EJBException should have been thrown");
+        } catch (EJBException e) {
+            // pass
+        }
+
+        red.start();
+
+        assertEquals(Host.RED, target.getHost());
+
     }