[jboss-cvs] JBossAS SVN: r79267 - projects/ejb3/trunk/testsuite/src/test/java/org/jboss/ejb3/test/stateful/unit.

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

Author: wolfc
Date: 2008-10-08 07:59:38 -0400 (Wed, 08 Oct 2008)
New Revision: 79267

Modified:
   projects/ejb3/trunk/testsuite/src/test/java/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java
Log:
EJBTHREE-1201: errors in testConcurrentClusteredTimeoutRemoval are now survivable

Modified: projects/ejb3/trunk/testsuite/src/test/java/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java
===================================================================
--- projects/ejb3/trunk/testsuite/src/test/java/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java	2008-10-08 11:58:10 UTC (rev 79266)
+++ projects/ejb3/trunk/testsuite/src/test/java/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java	2008-10-08 11:59:38 UTC (rev 79267)
@@ -128,17 +128,11 @@
       public boolean removed = false;
       public Exception failure = null;
       
-      public ConcurrentStatefulTimeoutClient(int id, int wait)
+      public ConcurrentStatefulTimeoutClient(int id, int wait) throws Exception
       {
-         try
-         {
-            this.id = id;
-            this.wait = wait;
-            sfsb = (StatefulTimeout)getInitialContext().lookup("StatefulClusteredTimeoutBean/remote");
-         }
-         catch (Exception e)
-         {
-         }
+         this.id = id;
+         this.wait = wait;
+         sfsb = (StatefulTimeout)getInitialContext().lookup("StatefulClusteredTimeoutBean/remote");
       }
       
       public void run()
@@ -168,6 +162,8 @@
             catch (Exception e)
             {
                failure = e;
+               log.debug("Concurrent invocation failed on " + sfsb, e);
+               return;
             }
          }
       }
@@ -685,7 +681,7 @@
    
    public void testConcurrentAccess() throws Exception
    {
-      ConcurrentStateful stateful = (ConcurrentStateful) new InitialContext().lookup("ConcurrentStateful");
+      ConcurrentStateful stateful = (ConcurrentStateful) new InitialContext().lookup("ConcurrentStatefulBean/remote");
       stateful.getState();
       
       StatefulInvoker[] invokers = new StatefulInvoker[2];