svn commit: r1050705 - /axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java

[ve...@apache.org]

Author: veithen
Date: Sat Dec 18 20:16:48 2010
New Revision: 1050705

URL: http://svn.apache.org/viewvc?rev=1050705&view=rev
Log:
Make sure that if useSeparateListener=true and the response code is 200, the transport is cleaned up properly to avoid connection pool starvation.

Modified:
    axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java

Modified: axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java
URL: http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java?rev=1050705&r1=1050704&r2=1050705&view=diff
==============================================================================
--- axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java (original)
+++ axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java Sat Dec 18 20:16:48 2010
@@ -682,6 +682,9 @@ public class SenderWorker extends Sandes
 			//if the syncResponseWas not built here and the client was not expecting a sync response. We will not try to execute 
 			//here. Doing so will cause a double invocation for a async message. 
 			if (msgCtx.getOptions().isUseSeparateListener()==true &&  !syncResponseBuilt) {
+			    // Since the client is not expecting a sync response, it will not (necessarily) call cleanup.
+			    // If we discard the response, then we need to clean up here.
+			    msgCtx.getTransportOut().getSender().cleanup(msgCtx);
 				return;
 			}