gdamour     2005/03/25 06:23:39

  Modified:    modules/core/src/test/org/openejb/server/axis
                        WSContainerTest.java
  Log:

  ServicePool uses now a Thread pool under the cover. This pool is either
  created or provided.
  
  Use the default Geronimo Thread pool under the cover of StandardServiceStack.
  
  Revision  Changes    Path
  1.3       +24 -3     
openejb/modules/core/src/test/org/openejb/server/axis/WSContainerTest.java
  
  Index: WSContainerTest.java
  ===================================================================
  RCS file: 
/home/projects/openejb/scm/openejb/modules/core/src/test/org/openejb/server/axis/WSContainerTest.java,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- WSContainerTest.java      18 Mar 2005 17:10:31 -0000      1.2
  +++ WSContainerTest.java      25 Mar 2005 11:23:39 -0000      1.3
  @@ -66,8 +66,12 @@
   import javax.xml.parsers.SAXParserFactory;
   
   import junit.framework.TestCase;
  +
  +import org.apache.geronimo.gbean.GBeanData;
   import org.apache.geronimo.kernel.Kernel;
  +import org.apache.geronimo.kernel.jmx.JMXUtil;
   import org.apache.geronimo.kernel.management.State;
  +import org.apache.geronimo.pool.ThreadPool;
   import org.apache.geronimo.axis.builder.AxisServiceBuilder;
   import org.apache.axis.description.JavaServiceDesc;
   import org.openejb.server.StandardServiceStackGBean;
  @@ -106,11 +110,13 @@
           ObjectName listener = SoapHttpListenerGBean.addGBean(kernel, 
"HTTPSOAP");
           ObjectName wsContainer = WSContainerGBean.addGBean(kernel, 
"HTTPSOAP", ejbContainer, listener, new URI("/test/service"), wsdlURI, 
serviceDesc);
           ObjectName server = HttpServerGBean.addGBean(kernel, "HTTPSOAP", 
listener);
  -        ObjectName stack = StandardServiceStackGBean.addGBean(kernel, 
"HTTPSOAP", 0, InetAddress.getByName("localhost"), null, 1, 5, null, null, 
server);
  +        ObjectName executor = buildExecutor(kernel);
  +        ObjectName stack = StandardServiceStackGBean.addGBean(kernel, 
"HTTPSOAP", 0, InetAddress.getByName("localhost"), null, null, null, executor, 
server);
   
           assertRunning(kernel, ejbContainer);
           assertRunning(kernel, wsContainer);
           assertRunning(kernel, listener);
  +        assertRunning(kernel, executor);
           assertRunning(kernel, server);
           assertRunning(kernel, stack);
   
  @@ -156,11 +162,13 @@
           ObjectName listener = SoapHttpListenerGBean.addGBean(kernel, 
"HTTPSOAP");
           ObjectName wsContainer = WSContainerGBean.addGBean(kernel, 
"HTTPSOAP", ejbContainer, listener, new URI("/services/Simple"), wsdlURI, 
serviceDesc);
           ObjectName server = HttpServerGBean.addGBean(kernel, "HTTPSOAP", 
listener);
  -        ObjectName stack = StandardServiceStackGBean.addGBean(kernel, 
"HTTPSOAP", 0, InetAddress.getByName("localhost"), null, 1, 5, null, null, 
server);
  +        ObjectName executor = buildExecutor(kernel);
  +        ObjectName stack = StandardServiceStackGBean.addGBean(kernel, 
"HTTPSOAP", 0, InetAddress.getByName("localhost"), null, null, null, executor, 
server);
   
           assertRunning(kernel, ejbContainer);
           assertRunning(kernel, wsContainer);
           assertRunning(kernel, listener);
  +        assertRunning(kernel, executor);
           assertRunning(kernel, server);
           assertRunning(kernel, stack);
   
  @@ -219,6 +227,19 @@
           return handler.result;
       }
   
  +    private ObjectName buildExecutor(Kernel kernel) throws Exception {
  +        ClassLoader cl = ThreadPool.class.getClassLoader();
  +        ObjectName executor = 
JMXUtil.getObjectName("openejb:name=ThreadPool");
  +        GBeanData gbean = new GBeanData(executor, ThreadPool.GBEAN_INFO);
  +        gbean.setAttribute("poolSize", new Integer(1));
  +        gbean.setAttribute("poolName", "Test");
  +        gbean.setAttribute("keepAliveTime", new Long(1000));
  +        gbean.setAttribute("classLoader", cl);
  +        kernel.loadGBean(gbean, cl);
  +        kernel.startGBean(executor);
  +        return executor;
  +    }
  +    
       private static class TestHandler extends DefaultHandler {
           String result;
           boolean found;
  
  
  

Reply via email to