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 2010/03/01 02:58:17 UTC

svn commit: r917353 - in /openejb/trunk/openejb3/container/openejb-core/src: main/java/org/apache/openejb/core/stateless/StatelessInstanceManager.java test/java/org/apache/openejb/core/stateless/StatelessInstanceManagerPoolingTest.java

Author: dblevins
Date: Mon Mar  1 01:58:16 2010
New Revision: 917353

URL: http://svn.apache.org/viewvc?rev=917353&view=rev
Log:
Pool pre-filling test case

Modified:
    openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/core/stateless/StatelessInstanceManager.java
    openejb/trunk/openejb3/container/openejb-core/src/test/java/org/apache/openejb/core/stateless/StatelessInstanceManagerPoolingTest.java

Modified: openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/core/stateless/StatelessInstanceManager.java
URL: http://svn.apache.org/viewvc/openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/core/stateless/StatelessInstanceManager.java?rev=917353&r1=917352&r2=917353&view=diff
==============================================================================
--- openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/core/stateless/StatelessInstanceManager.java (original)
+++ openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/core/stateless/StatelessInstanceManager.java Mon Mar  1 01:58:16 2010
@@ -359,13 +359,16 @@
         Data data = new Data(max, strict, min, accessTimeout);
         deploymentInfo.setContainerData(data);
 
+        ThreadContext ctx = new ThreadContext(deploymentInfo, null);
+        ThreadContext oldCallContext = ThreadContext.enter(ctx);
         try {
-            ThreadContext ctx = new ThreadContext(deploymentInfo, null);
             for (int i = 0; i < min; i++) {
                 data.getPool().add(ceateInstance(ctx));
             }
         } catch (OpenEJBException e) {
             logger.error("Unable to pre-fill pool to mimimum size: " + min + " for deployment '" + deploymentInfo.getDeploymentID() + "'", e);
+        } finally {
+             ThreadContext.exit(oldCallContext);
         }
     }
 

Modified: openejb/trunk/openejb3/container/openejb-core/src/test/java/org/apache/openejb/core/stateless/StatelessInstanceManagerPoolingTest.java
URL: http://svn.apache.org/viewvc/openejb/trunk/openejb3/container/openejb-core/src/test/java/org/apache/openejb/core/stateless/StatelessInstanceManagerPoolingTest.java?rev=917353&r1=917352&r2=917353&view=diff
==============================================================================
--- openejb/trunk/openejb3/container/openejb-core/src/test/java/org/apache/openejb/core/stateless/StatelessInstanceManagerPoolingTest.java (original)
+++ openejb/trunk/openejb3/container/openejb-core/src/test/java/org/apache/openejb/core/stateless/StatelessInstanceManagerPoolingTest.java Mon Mar  1 01:58:16 2010
@@ -203,6 +203,7 @@
         StatelessSessionContainerInfo statelessContainerInfo = config.configureService(StatelessSessionContainerInfo.class);
         statelessContainerInfo.properties.setProperty("TimeOut", "100");
         statelessContainerInfo.properties.setProperty("PoolSize", "10");
+        statelessContainerInfo.properties.setProperty("PoolMin", "2");
         statelessContainerInfo.properties.setProperty("StrictPooling", "true");
         assembler.createContainer(statelessContainerInfo);