User: peter   
  Date: 01/03/01 05:23:20

  Modified:    src/main/org/jboss/test/cts/test AllJUnitTests.java
                        bmpTest.java
  Log:
  Added container monitor code to verify when EJB callbacks
  are made by the container to the bean instance.  The
  callbacks are transmitted to the client via JMS.
  
  Revision  Changes    Path
  1.9       +14 -11    jbosstest/src/main/org/jboss/test/cts/test/AllJUnitTests.java
  
  Index: AllJUnitTests.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/jbosstest/src/main/org/jboss/test/cts/test/AllJUnitTests.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- AllJUnitTests.java        2001/02/18 16:04:47     1.8
  +++ AllJUnitTests.java        2001/03/01 13:23:20     1.9
  @@ -55,27 +55,30 @@
            System.exit(0);
         }
   
  -      //suite.addTest(new StatefulSessionTest("testBasicSession"));
  -      //suite.addTest(new StatefulSessionTest("testEJBHomeInterface"));
  +      suite.addTest(new StatefulSessionTest("testBasicSession"));
  +      suite.addTest(new StatefulSessionTest("testEJBHomeInterface"));
         // Broken 12/05/00
  -      //suite.addTest(new StatefulSessionTest("testRemoveSessionObject"));
  -      //suite.addTest(new StatefulSessionTest("testSerialization"));
  -      //suite.addTest(new StatefulSessionTest("testUnSerialization"));
  -      //suite.addTest(new StatefulSessionTest("testCompareSerializeGetPK"));
  -      //suite.addTest(new StatefulSessionTest("testProbeBeanContext"));
  -      //suite.addTest(new StatefulSessionTest("testLoopback"));
  -      //suite.addTest(new StatefulSessionTest("testUserTrx"));
  +      suite.addTest(new StatefulSessionTest("testRemoveSessionObject"));
  +      suite.addTest(new StatefulSessionTest("testSerialization"));
  +      suite.addTest(new StatefulSessionTest("testUnSerialization"));
  +      suite.addTest(new StatefulSessionTest("testCompareSerializeGetPK"));
  +      suite.addTest(new StatefulSessionTest("testProbeBeanContext"));
  +      suite.addTest(new StatefulSessionTest("testLoopback"));
  +      suite.addTest(new StatefulSessionTest("testUserTrx"));
   
  -      //suite.addTest(new StatelessSessionTest("testBasicStatelessSession"));
  +      suite.addTest(new StatelessSessionTest("testBasicStatelessSession"));
   
  +      suite.addTest(new bmpTest("testProbeContainerCallbacks"));
  +
         suite.addTest(new bmpTest("testEjbCreate"));
         suite.addTest(new bmpTest("testEjbFinder"));
         suite.addTest(new bmpTest("testEjbRemove"));
         suite.addTest(new bmpTest("testEjbLifeCycle"));
  +
         suite.addTest(new bmpTest("testPrimaryKeyObjectIdentity"));
         suite.addTest(new bmpTest("testEjbRemoteIF"));
         suite.addTest(new bmpTest("testEntityHandle"));
  -
  +     
         return suite;
      }
   }
  
  
  
  1.4       +60 -0     jbosstest/src/main/org/jboss/test/cts/test/bmpTest.java
  
  Index: bmpTest.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/jbosstest/src/main/org/jboss/test/cts/test/bmpTest.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- bmpTest.java      2001/02/18 16:04:47     1.3
  +++ bmpTest.java      2001/03/01 13:23:20     1.4
  @@ -7,6 +7,7 @@
   import javax.rmi.PortableRemoteObject;
   import java.rmi.*;
   import java.util.*;
  +import org.jboss.test.cts.jms.*;
   import org.jboss.test.cts.interfaces.*;
   import org.jboss.test.cts.keys.*;
   import org.jboss.test.util.ejb.*;
  @@ -25,6 +26,7 @@
   {
      static boolean         deployed = false;
      private SessionContext ctx      = null;
  +   private ContainerMBox mbx = null; 
      public static final String BEAN_NAME = "GuysName";
      public static final String BEAN_OTHER_NAME = "OtherGuysName";
      public static final String BEAN_PK_007 = "007";
  @@ -494,6 +496,61 @@
        }
      }
   
  +   /**
  +    * Method testProbeContainerCallbacks
  +    *
  +    */
  +
  +   public void testProbeContainerCallbacks ()
  +   {
  +      System.out.println(
  +         "**************************************************************");
  +      System.out.println("     testProbeContainerCallbacks()");
  +
  +      CtsBmp bean = null;
  +
  +      try
  +      {
  +         Context    ctx  = new InitialContext();
  +         CtsBmpHome home =
  +            ( CtsBmpHome ) new InitialContext().lookup("ejbcts/BMPBean");
  +
  +         mbx.clearMessages();
  +         System.out.println("new bean");
  +         AccountPK pk = new AccountPK(BEAN_PK_007);
  +         bean = home.create(pk, bmpTest.BEAN_NAME);
  +         System.out.println("Check for set entity context, create and post create 
messages" );
  +         Thread.sleep(1500);
  +         assert(mbx.messageReceived(ContainerMBox.SET_ENTITY_CONTEXT_MSG));
  +         assert(mbx.messageReceived(ContainerMBox.EJB_CREATE_MSG));
  +         assert(mbx.messageReceived(ContainerMBox.EJB_POST_CREATE_MSG));
  +         System.out.println("OK");
  +         // Execute a business method
  +         System.out.println("Calling setter as a business method");
  +         bean.setPersonsName(bmpTest.BEAN_OTHER_NAME);
  +         System.out.println("OK");
  +
  +         // Remove
  +         System.out.println( "Remove the bean" );
  +         bean.remove();
  +         Thread.sleep(2000);
  +         System.out.println("OK");
  +         assert(mbx.messageReceived(ContainerMBox.EJB_STORE_MSG));
  +         assert(mbx.messageReceived(ContainerMBox.EJB_REMOVE_MSG));
  +         System.out.println("All callbacks received as expected");
  +
  +      }
  +      catch (Exception ex)
  +      {
  +         ex.printStackTrace();
  +         fail("testEjbCreate has failed!");
  +      }
  +
  +      System.out.println(
  +         "**************************************************************");
  +   }
  +
  +  
      // Used to test passing a Entity bean as a parameter.
      private boolean gotRefOkay ( CtsBmp bean, String expectedName )
      {
  @@ -513,6 +570,9 @@
      protected void setUp ()
         throws Exception
      {
  +      System.out.println( "Build Container MBX" );
  +      mbx = new ContainerMBox( );  
  +
         if (deployed) return;
   
         deployed = true;
  
  
  

Reply via email to