You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by im...@apache.org on 2014/05/02 13:33:43 UTC

git commit: Changed transport.equals(port.getProtocol()) to transport.startsWith(port.getProtocol()) to let protocols to be defined with suffixes

Repository: incubator-stratos
Updated Branches:
  refs/heads/master 2dbaae431 -> 3d3fc9d31


Changed transport.equals(port.getProtocol()) to transport.startsWith(port.getProtocol()) to let protocols to be defined with suffixes


Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/3d3fc9d3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/3d3fc9d3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/3d3fc9d3

Branch: refs/heads/master
Commit: 3d3fc9d31199e4b108ec034ca4ab809f998c7e3f
Parents: 2dbaae4
Author: Imesh Gunaratne <im...@apache.org>
Authored: Fri May 2 17:03:15 2014 +0530
Committer: Imesh Gunaratne <im...@apache.org>
Committed: Fri May 2 17:03:15 2014 +0530

----------------------------------------------------------------------
 .../load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/3d3fc9d3/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java
index 1ffdb50..9e570fc 100644
--- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java
+++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java
@@ -317,7 +317,7 @@ public class TenantAwareLoadBalanceEndpoint extends org.apache.synapse.endpoints
         if ((member != null) && (member.getPorts() != null)) {
             Port outgoingPort = member.getPort(incomingPort);
             if (outgoingPort != null) {
-                if (!transport.equals(outgoingPort.getProtocol())) {
+                if (!transport.startsWith(outgoingPort.getProtocol())) {
                     if (log.isErrorEnabled()) {
                         String message = String.format("Transport %s is not valid for port %d", transport, incomingPort);
                         if (log.isErrorEnabled()) {