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/24 11:03:29 UTC
stratos git commit: Adding kubernetes access URLs for all minions
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 <im...@apache.org>
Authored: Sun May 24 14:33:07 2015 +0530
Committer: Imesh Gunaratne <im...@apache.org>
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) {