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);
 


Reply via email to