You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-commits@axis.apache.org by ve...@apache.org on 2010/12/18 21:50:54 UTC
svn commit: r1050713 - in /axis/axis2/java/sandesha/branches/1_4: ./
modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java
Author: veithen
Date: Sat Dec 18 20:50:54 2010
New Revision: 1050713
URL: http://svn.apache.org/viewvc?rev=1050713&view=rev
Log:
Merged r1050705 to the 1.4 branch. This should make the test suite pass with Axis2 1.5.4-SNAPSHOT.
Modified:
axis/axis2/java/sandesha/branches/1_4/ (props changed)
axis/axis2/java/sandesha/branches/1_4/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java
Propchange: axis/axis2/java/sandesha/branches/1_4/
------------------------------------------------------------------------------
svn:mergeinfo = /axis/axis2/java/sandesha/trunk:1050705
Modified: axis/axis2/java/sandesha/branches/1_4/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java
URL: http://svn.apache.org/viewvc/axis/axis2/java/sandesha/branches/1_4/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java?rev=1050713&r1=1050712&r2=1050713&view=diff
==============================================================================
--- axis/axis2/java/sandesha/branches/1_4/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java (original)
+++ axis/axis2/java/sandesha/branches/1_4/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java Sat Dec 18 20:50:54 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;
}