Author: amilas
Date: Tue Nov 17 11:54:27 2009
New Revision: 881248
URL: http://svn.apache.org/viewvc?rev=881248&view=rev
Log:
register mbean and initialize pool only if it has not initailed, since axis2
call twice this method
Modified:
webservices/commons/branches/modules/transport/1.0.0/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
Modified:
webservices/commons/branches/modules/transport/1.0.0/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
URL:
http://svn.apache.org/viewvc/webservices/commons/branches/modules/transport/1.0.0/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java?rev=881248&r1=881247&r2=881248&view=diff
==============================================================================
---
webservices/commons/branches/modules/transport/1.0.0/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
(original)
+++
webservices/commons/branches/modules/transport/1.0.0/modules/base/src/main/java/org/apache/axis2/transport/base/AbstractTransportListener.java
Tue Nov 17 11:54:27 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) { // FIXME <-- workaround for
AXIS2-4552
+ 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
@@ -129,8 +132,11 @@
});
// register with JMX
- mbeanSupport = new TransportMBeanSupport(this, getTransportName());
- mbeanSupport.register();
+ if (mbeanSupport == null) { // FIXME <-- workaround for AXIS2-4552
+ mbeanSupport = new TransportMBeanSupport(this, getTransportName());
+ mbeanSupport.register();
+ }
+
}
public void destroy() {
