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

[hiranya]

Author: hiranya
Date: Fri Feb 26 12:51:18 2010
New Revision: 916664

URL: http://svn.apache.org/viewvc?rev=916664&view=rev
Log:
Fixing a bug in the load balance endpoint impl. Using the correct port in the 
target address.


Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java?rev=916664&r1=916663&r2=916664&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
 Fri Feb 26 12:51:18 2010
@@ -120,9 +120,15 @@
                         throw new SynapseException(msg, e);
                     }
                 }
+
+                int port = currentMember.getHttpPort();
+                if ("https".equals(transport)) {
+                    port = currentMember.getHttpsPort();
+                }
+
                 EndpointReference epr =
                         new EndpointReference(transport + "://" + 
currentMember.getHostName() +
-                                              ":" + 
currentMember.getHttpPort() + address);
+                                ":" + port + address);
                 synCtx.setTo(epr);
                 if (isFailover()) {
                     synCtx.getEnvelope().build();