You are viewing a plain text version of this content. The canonical link for it is here.
Posted to scm@geronimo.apache.org by db...@apache.org on 2010/04/06 15:28:46 UTC
svn commit: r931146 -
/geronimo/server/branches/2.2/plugins/openejb/geronimo-openejb-clustering-wadi/src/main/java/org/apache/geronimo/openejb/cluster/container/stateless/ClusteredStatelessContainer.java
Author: dblevins
Date: Tue Apr 6 13:28:46 2010
New Revision: 931146
URL: http://svn.apache.org/viewvc?rev=931146&view=rev
Log:
Updated for the lastest options
Modified:
geronimo/server/branches/2.2/plugins/openejb/geronimo-openejb-clustering-wadi/src/main/java/org/apache/geronimo/openejb/cluster/container/stateless/ClusteredStatelessContainer.java
Modified: geronimo/server/branches/2.2/plugins/openejb/geronimo-openejb-clustering-wadi/src/main/java/org/apache/geronimo/openejb/cluster/container/stateless/ClusteredStatelessContainer.java
URL: http://svn.apache.org/viewvc/geronimo/server/branches/2.2/plugins/openejb/geronimo-openejb-clustering-wadi/src/main/java/org/apache/geronimo/openejb/cluster/container/stateless/ClusteredStatelessContainer.java?rev=931146&r1=931145&r2=931146&view=diff
==============================================================================
--- geronimo/server/branches/2.2/plugins/openejb/geronimo-openejb-clustering-wadi/src/main/java/org/apache/geronimo/openejb/cluster/container/stateless/ClusteredStatelessContainer.java (original)
+++ geronimo/server/branches/2.2/plugins/openejb/geronimo-openejb-clustering-wadi/src/main/java/org/apache/geronimo/openejb/cluster/container/stateless/ClusteredStatelessContainer.java Tue Apr 6 13:28:46 2010
@@ -34,6 +34,7 @@ import org.apache.openejb.ClusteredRPCCo
import org.apache.openejb.DeploymentInfo;
import org.apache.openejb.OpenEJBException;
import org.apache.openejb.util.Duration;
+import org.apache.openejb.util.Pool;
import org.apache.openejb.core.stateless.StatelessContainer;
import org.apache.openejb.spi.SecurityService;
import org.codehaus.wadi.core.manager.Manager;
@@ -50,12 +51,19 @@ public class ClusteredStatelessContainer
private final Map<Object, NetworkConnectorTracker> deploymentIdToNetworkConnectorTracker;
public ClusteredStatelessContainer(Object id, SecurityService securityService, int timeOut, int poolSize, boolean strictPooling) throws OpenEJBException {
- super(id, securityService, new Duration(timeOut, TimeUnit.MILLISECONDS), 0, poolSize, strictPooling);
+ super(id, securityService, new Duration(timeOut, TimeUnit.MILLISECONDS), builder(poolSize, strictPooling), 5);
deploymentIdToManager = new ConcurrentHashMap<Object, Manager>();
deploymentIdToNetworkConnectorTracker = new ConcurrentHashMap<Object, NetworkConnectorTracker>();
}
+ private static Pool.Builder builder(int poolSize, boolean strictPooling) {
+ final Pool.Builder builder = new Pool.Builder();
+ builder.setPoolMax(poolSize);
+ builder.setStrictPooling(strictPooling);
+ return builder;
+ }
+
public void addSessionManager(Object deploymentId, SessionManager sessionManager) {