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 <[email protected]> Authored: Fri May 2 17:03:15 2014 +0530 Committer: Imesh Gunaratne <[email protected]> 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()) {
