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;
}
