svn commit: r915687 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/LoadbalanceEndpoint.java

[ruwan]

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();