svn commit: r891682 - /webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/engine/ListenerManager.java

[am...@apache.org]

Author: amilas
Date: Thu Dec 17 12:51:47 2009
New Revision: 891682

URL: http://svn.apache.org/viewvc?rev=891682&view=rev
Log:
need to destory all the transports at a termination since most of the transports
start worker pools at init method

Modified:
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/engine/ListenerManager.java

Modified: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/engine/ListenerManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/engine/ListenerManager.java?rev=891682&r1=891681&r2=891682&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/engine/ListenerManager.java (original)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/engine/ListenerManager.java Thu Dec 17 12:51:47 2009
@@ -287,10 +287,15 @@
     public void destroy() throws AxisFault {
         stop();
         this.configctx.setTransportManager(null);
-        for (Object o : startedTransports.values()) {
-            TransportListener transportListener = (TransportListener)o;
+        // need to destory all the transports not only the started ones
+        // most of the transports create the worker pool at the init method.
+        TransportInDescription transportInDescription;
+        for (Object o : configctx.getAxisConfiguration().getAxisConfiguration().getTransportsIn().values()) {
+            transportInDescription = (TransportInDescription) o;
+            TransportListener transportListener = transportInDescription.getReceiver();
             transportListener.destroy();
         }
+
         this.startedTransports.clear();
         this.configctx = null;
         defaultConfigurationContext = null;