You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ru...@apache.org on 2010/02/24 06:44:25 UTC
svn commit: r915687 -
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/LoadbalanceEndpoint.java
Author: ruwan
Date: Wed Feb 24 05:44:24 2010
New Revision: 915687
URL: http://svn.apache.org/viewvc?rev=915687&view=rev
Log:
Fixing an issue in the transport protocol selection
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/LoadbalanceEndpoint.java
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/LoadbalanceEndpoint.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/LoadbalanceEndpoint.java?rev=915687&r1=915686&r2=915687&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/LoadbalanceEndpoint.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/LoadbalanceEndpoint.java Wed Feb 24 05:44:24 2010
@@ -22,6 +22,7 @@
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.clustering.Member;
+import org.apache.http.protocol.HTTP;
import org.apache.synapse.FaultHandler;
import org.apache.synapse.MessageContext;
import org.apache.synapse.SynapseConstants;
@@ -148,8 +149,9 @@
}
}
EndpointReference epr =
- new EndpointReference(transport + "://" + currentMember.getHostName() +
- ":" + currentMember.getHttpPort() + address);
+ new EndpointReference(transport + "://" + currentMember.getHostName()
+ + ":" + ("http".equals(transport) ? currentMember.getHttpPort() :
+ currentMember.getHttpPort())+ address);
synCtx.setTo(epr);
if (failover) {
synCtx.getEnvelope().build();