Repository: stratos Updated Branches: refs/heads/master a15ed9636 -> 64d3493d3
Adding kubernetes access URLs for all minions Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/64d3493d Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/64d3493d Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/64d3493d Branch: refs/heads/master Commit: 64d3493d3fa9665fe1690840d875d448a1eb6861 Parents: a15ed96 Author: Imesh Gunaratne <[email protected]> Authored: Sun May 24 14:33:07 2015 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Sun May 24 14:33:07 2015 +0530 ---------------------------------------------------------------------- .../topology/ClusterInstanceActivatedProcessor.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/64d3493d/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java index 4b24ed0..09d8d84 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java @@ -119,11 +119,14 @@ public class ClusterInstanceActivatedProcessor extends MessageProcessor { try { // Generate access URLs for kubernetes services for (KubernetesService kubernetesService : kubernetesServices) { + // Public IP = Kubernetes minion public IP String[] publicIPs = kubernetesService.getPublicIPs(); if((publicIPs != null) && (publicIPs.length > 0)) { - URL accessURL = new URL(kubernetesService.getProtocol(), publicIPs[0], - kubernetesService.getPort(), ""); - cluster.addAccessUrl(accessURL.toString()); + for(String publicIP : publicIPs) { + URL accessURL = new URL(kubernetesService.getProtocol(), publicIP, + kubernetesService.getPort(), ""); + cluster.addAccessUrl(accessURL.toString()); + } } } } catch (Exception e) {
