sending Cluster Terminated event when the Cluster Monitor is not available/failed
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/128fe3e0 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/128fe3e0 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/128fe3e0 Branch: refs/heads/4.0.0-grouping Commit: 128fe3e08b531f1353102282c0e6f17038902b66 Parents: 636d9bb Author: Isuru Haththotuwa <[email protected]> Authored: Tue Oct 28 21:26:51 2014 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Tue Oct 28 21:26:51 2014 +0530 ---------------------------------------------------------------------- .../receiver/topology/AutoscalerTopologyEventReceiver.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/128fe3e0/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java index bff46c2..1423385 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java @@ -395,6 +395,11 @@ public class AutoscalerTopologyEventReceiver implements Runnable { } } else { log.warn("No Cluster Monitor found for cluster id " + clusterData.getClusterId()); + // if Cluster Monitor is not found, still the Cluster Terminated + // should be sent to update the parent Monitor + StatusEventPublisher.sendClusterTerminatedEvent( + applicationUndeployedEvent.getApplicationId(), + clusterData.getServiceType(), clusterData.getClusterId()); } }
