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 2015/05/21 17:07:09 UTC
stratos git commit: Fixing issue in setting kubernetes service access
URLs
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 <im...@apache.org>
Authored: Thu May 21 20:48:19 2015 +0530
Committer: Imesh Gunaratne <im...@apache.org>
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());