svn commit: r388049 - /webservices/axis/trunk/java/src/org/apache/axis/client/AxisClient.java

[ga...@apache.org]

Author: gawor
Date: Wed Mar 22 21:36:16 2006
New Revision: 388049

URL: http://svn.apache.org/viewcvs?rev=388049&view=rev
Log:
use task manager (if set) for one way calls

Modified:
    webservices/axis/trunk/java/src/org/apache/axis/client/AxisClient.java

Modified: webservices/axis/trunk/java/src/org/apache/axis/client/AxisClient.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/src/org/apache/axis/client/AxisClient.java?rev=388049&r1=388048&r2=388049&view=diff
==============================================================================
--- webservices/axis/trunk/java/src/org/apache/axis/client/AxisClient.java (original)
+++ webservices/axis/trunk/java/src/org/apache/axis/client/AxisClient.java Wed Mar 22 21:36:16 2006
@@ -23,6 +23,8 @@
 import org.apache.axis.Handler;
 import org.apache.axis.MessageContext;
 import org.apache.axis.components.logger.LogFactory;
+import org.apache.axis.components.threadpool.TaskManager;
+import org.apache.axis.components.threadpool.TaskManagerFactory;
 import org.apache.axis.configuration.EngineConfigurationFactoryFinder;
 import org.apache.axis.handlers.HandlerInfoChainFactory;
 import org.apache.axis.handlers.soap.MustUnderstandChecker;
@@ -49,6 +51,9 @@
     protected static Log log =
         LogFactory.getLog(AxisClient.class.getName());
 
+    protected static TaskManager taskManager = 
+        TaskManagerFactory.getTaskManager();
+
     MustUnderstandChecker checker     = new MustUnderstandChecker(null);
     HandlerChain          handlerImpl = null ;
 
@@ -166,12 +171,15 @@
             invokeTransport( msgContext );
           }
           catch( Exception exp ) {
-            exp.printStackTrace();
             log.debug( Messages.getMessage( "exceptionPrinting" ) , exp );
           }
         }
       };
-      (new Thread(runnable)).start();
+      if (taskManager == null) {
+          (new Thread(runnable)).start();
+      } else {
+          taskManager.execute(runnable);
+      }
     }
 
     public void invokeInbound(MessageContext msgContext) throws Exception {