Repository: stratos Updated Branches: refs/heads/master 3b9d698c2 -> 9282761ab
Fixing issue in setting kubernetes service access URLs Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/9282761a Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/9282761a Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/9282761a Branch: refs/heads/master Commit: 9282761abb2186d9a85819e181d77b020f668da1 Parents: 3b9d698 Author: Imesh Gunaratne <[email protected]> Authored: Thu May 21 20:48:19 2015 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Thu May 21 20:48:32 2015 +0530 ---------------------------------------------------------------------- .../ClusterInstanceActivatedProcessor.java | 23 ++++++++++---------- 1 file changed, 11 insertions(+), 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/9282761a/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 c783ddc..4b24ed0 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 @@ -116,20 +116,19 @@ public class ClusterInstanceActivatedProcessor extends MessageProcessor { if (kubernetesServices != null) { // Set kubernetes services cluster.setKubernetesServices(kubernetesServices); - } - - try { - // Generate access URLs for kubernetes services - for (KubernetesService kubernetesService : kubernetesServices) { - String[] publicIPs = kubernetesService.getPublicIPs(); - if((publicIPs != null) && (publicIPs.length > 0)) { - URL accessURL = new URL(kubernetesService.getProtocol(), publicIPs[0], - kubernetesService.getPort(), ""); - cluster.addAccessUrl(accessURL.toString()); + try { + // Generate access URLs for kubernetes services + for (KubernetesService kubernetesService : kubernetesServices) { + String[] publicIPs = kubernetesService.getPublicIPs(); + if((publicIPs != null) && (publicIPs.length > 0)) { + URL accessURL = new URL(kubernetesService.getProtocol(), publicIPs[0], + kubernetesService.getPort(), ""); + cluster.addAccessUrl(accessURL.toString()); + } } + } catch (Exception e) { + log.error("Could not create access URLs for Kubernetes services", e); } - } catch (Exception e) { - log.error("Could not create access URLs for Kubernetes services"); } ClusterInstance context = cluster.getInstanceContexts(event.getInstanceId());
