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