[jBoss-Dev] CVS update: jbosstest/src/main/org/jboss/test/cts/ejbStatefulSessionBean.java

[jBoss CVS Development]

  User: peter   
  Date: 01/01/04 17:24:10

  Modified:    src/main/org/jboss/test/cts/ejb StatefulSessionBean.java
  Log:
  Added loopback test.
  
  Revision  Changes    Path
  1.5       +86 -20    
jbosstest/src/main/org/jboss/test/cts/ejb/StatefulSessionBean.java
  
  Index: StatefulSessionBean.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/jbosstest/src/main/org/jboss/test/cts/ejb/StatefulSessionBean.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- StatefulSessionBean.java  2001/01/04 04:43:57     1.4
  +++ StatefulSessionBean.java  2001/01/05 01:24:10     1.5
  @@ -5,8 +5,10 @@
   import org.jboss.test.util.ejb.*;
   import java.security.Principal;
   import java.io.*;
  +import javax.naming.*;
   import java.util.*;
   import javax.ejb.*;
  +import org.jboss.test.cts.interfaces.*;
   import org.jboss.test.util.ejb.SessionSupport;
   
   
  @@ -14,11 +16,12 @@
    *
    *   @see <related>
    *   @author $Author: peter $
  - *   @version $Revision: 1.4 $
  + *   @version $Revision: 1.5 $
    */
   
   public class StatefulSessionBean
  -   extends SessionSupport implements SessionSynchronization
  +   extends SessionSupport
  +   implements SessionSynchronization
   {
      private int counter;
   
  @@ -35,21 +38,41 @@
      {
      }
   
  -    public void afterBegin( )
  -    {
  -     System.out.println( "Calling afterBegin( )..." );
  -    }
  -
  -    public void afterCompletion(boolean isCommited)
  -    {
  -     System.out.println( "Calling afterCompletion( )" );
  -     System.out.println( "isCommited = " + isCommited );
  -    }
  -
  -    public void beforeCompletion( )
  -    {
  -     System.out.println( "Calling beforeCompletion( )..." );
  -    }
  +   /**
  +    * Method afterBegin
  +    *
  +    *
  +    */
  +
  +   public void afterBegin ()
  +   {
  +      System.out.println("Calling afterBegin( )...");
  +   }
  +
  +   /**
  +    * Method afterCompletion
  +    *
  +    *
  +    * @param isCommited
  +    *
  +    */
  +
  +   public void afterCompletion (boolean isCommited)
  +   {
  +      System.out.println("Calling afterCompletion( )");
  +      System.out.println("isCommited = " + isCommited);
  +   }
  +
  +   /**
  +    * Method beforeCompletion
  +    *
  +    *
  +    */
  +
  +   public void beforeCompletion ()
  +   {
  +      System.out.println("Calling beforeCompletion( )...");
  +   }
   
      /**
       * Method method1
  @@ -142,12 +165,55 @@
         //Principal principal = sessionCtx.getCallerPrincipal();
         //ctx.principleName = principal.getName();
         //ctx.isCallerInRole = sessionCtx.isCallerInRole();
  +      System.out.println("calling setRollbackOnly( ) on context");
  +      sessionCtx.setRollbackOnly();
   
  -      System.out.println( "calling setRollbackOnly( ) on context" );
  -      sessionCtx.setRollbackOnly( );
  -      ctx.isRollbackOnly = new Boolean(sessionCtx.getRollbackOnly( ));
  +      ctx.isRollbackOnly = new Boolean(sessionCtx.getRollbackOnly());
   
         return ctx;
  +   }
  +
  +   /**
  +    * Method loopbackTest
  +    *
  +    *
  +    */
  +
  +   public void loopbackTest ()
  +     throws java.rmi.RemoteException
  +   {
  +      try
  +      {
  +        Context             ctx         = new InitialContext();
  +        StatefulSessionHome home        =
  +           ( StatefulSessionHome ) ctx.lookup("ejbcts/StatefulSessionBean");
  +        StatefulSession     sessionBean = home.create();
  +        sessionBean.loopbackTest(sessionCtx.getEJBObject());
  +      }
  +      catch( javax.naming.NamingException nex )
  +      {
  +       System.out.println( "Could not locate bean instance" );
  +      }
  +   }
  +
  +   /**
  +    * Method loopbackTest
  +    *
  +    *
  +    * @param obj
  +    *
  +    * @throws java.rmi.RemoteException
  +    *
  +    */
  +
  +   public void loopbackTest (EJBObject obj)
  +      throws java.rmi.RemoteException
  +   {
  +
  +      // This should throw an exception. 
  +      StatefulSession bean = ( StatefulSession ) obj;
  +
  +      bean.method1("Hello");
      }
   }