Author: amilas
Date: Fri Nov 13 05:45:36 2009
New Revision: 835750
URL: http://svn.apache.org/viewvc?rev=835750&view=rev
Log:
initialize worker pool only if it is not set to avoid possible worker pool
leakage
Modified:
webservices/commons/trunk/modules/transport/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
Modified:
webservices/commons/trunk/modules/transport/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
URL:
http://svn.apache.org/viewvc/webservices/commons/trunk/modules/transport/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java?rev=835750&r1=835749&r2=835750&view=diff
==============================================================================
---
webservices/commons/trunk/modules/transport/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
(original)
+++
webservices/commons/trunk/modules/transport/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
Fri Nov 13 05:45:36 2009
@@ -100,13 +100,16 @@
//this.workerPool = cfgCtx.getThreadPool(); not yet implemented
throw new AxisFault("Unsupported thread pool for task execution -
Axis2 thread pool");
} else {
- this.workerPool = WorkerPoolFactory.getWorkerPool(
- config.getServerCoreThreads(),
- config.getServerMaxThreads(),
- config.getServerKeepalive(),
- config.getServerQueueLen(),
- getTransportName() + "Server Worker thread group",
- getTransportName() + "-Worker");
+ if (this.workerPool == null) {
+ this.workerPool = WorkerPoolFactory.getWorkerPool(
+ config.getServerCoreThreads(),
+ config.getServerMaxThreads(),
+ config.getServerKeepalive(),
+ config.getServerQueueLen(),
+ getTransportName() + "Server Worker thread group",
+ getTransportName() + "-Worker");
+ }
+
}
// register to receive updates on services for lifetime management
