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