Updated Branches: refs/heads/master 314a58993 -> 70c184f87
Add lb cluster moniter for full topology receiver Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/a1fea083 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/a1fea083 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/a1fea083 Branch: refs/heads/master Commit: a1fea083bed50ffddbbda70c588d51e3d712f22b Parents: 47a5f65 Author: Udara Liyanage <[email protected]> Authored: Wed Dec 18 17:01:53 2013 -0500 Committer: Udara Liyanage <[email protected]> Committed: Wed Dec 18 17:01:53 2013 -0500 ---------------------------------------------------------------------- .../autoscaler/topology/AutoscalerTopologyReceiver.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a1fea083/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java index 9372fe0..7dabf19 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java @@ -86,8 +86,13 @@ public class AutoscalerTopologyReceiver implements Runnable { TopologyManager.acquireReadLock(); for(Service service : TopologyManager.getTopology().getServices()) { for(Cluster cluster : service.getClusters()) { - - Thread th = new Thread(new ClusterMonitorAdder(cluster)); + Thread th; + if(cluster.isLbCluster()){ + th= new Thread(new LBClusterMonitorAdder(cluster)); + }else{ + th = new Thread(new ClusterMonitorAdder(cluster)); + } + th.start(); } }
