You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by ch...@apache.org on 2007/03/12 10:52:59 UTC
svn commit: r517157 - in
/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse:
core/axis2/Axis2FlexibleMEPClient.java endpoints/FailoverEndpoint.java
Author: chathura_ce
Date: Mon Mar 12 02:52:58 2007
New Revision: 517157
URL: http://svn.apache.org/viewvc?view=rev&rev=517157
Log:
Fixed an issue in FailoverEndpoint. FailoverEndpoint should build the envelop before sending, so that it can resent the same envelop if an failure occures.
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/FailoverEndpoint.java
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java?view=diff&rev=517157&r1=517156&r2=517157
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java Mon Mar 12 02:52:58 2007
@@ -200,7 +200,7 @@
newMC.setDoingMTOM(ori.isDoingMTOM());
newMC.setServerSide(false);
- // set SOAP envelope on the message context, removing WS-A headers
+ // set SOAP envelope on the message context, removing WS-A headers
newMC.setEnvelope(ori.getEnvelope());
removeAddressingHeaders(newMC);
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/FailoverEndpoint.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/FailoverEndpoint.java?view=diff&rev=517157&r1=517156&r2=517157
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/FailoverEndpoint.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/FailoverEndpoint.java Mon Mar 12 02:52:58 2007
@@ -42,6 +42,11 @@
public void send(MessageContext synMessageContext) {
+ // We have to build the envelop if we are supporting failover.
+ // Failover should sent the original message multiple times if failures occur. So we have to
+ // access the envelop multiple times.
+ synMessageContext.getEnvelope().build();
+
if (currentEndpoint.isActive()) {
currentEndpoint.send(synMessageContext);
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org