Repository: stratos Updated Branches: refs/heads/4.0.0-grouping 473f25b2c -> b9f7ea275
correcting the log and notifying listeners Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/b9f7ea27 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/b9f7ea27 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/b9f7ea27 Branch: refs/heads/4.0.0-grouping Commit: b9f7ea275a2e14cbb19c000c3bde49f02bf526fe Parents: 473f25b Author: Isuru Haththotuwa <[email protected]> Authored: Wed Oct 22 15:12:57 2014 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Wed Oct 22 15:12:57 2014 +0530 ---------------------------------------------------------------------- .../topology/ApplicationUndeployedMessageProcessor.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/b9f7ea27/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationUndeployedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationUndeployedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationUndeployedMessageProcessor.java index 3f397c0..8915e4f 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationUndeployedMessageProcessor.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationUndeployedMessageProcessor.java @@ -31,7 +31,7 @@ import java.util.Set; public class ApplicationUndeployedMessageProcessor extends MessageProcessor { - private static final Log log = LogFactory.getLog(ApplicationCreatedMessageProcessor.class); + private static final Log log = LogFactory.getLog(ApplicationUndeployedMessageProcessor.class); private MessageProcessor nextProcessor; @@ -113,9 +113,9 @@ public class ApplicationUndeployedMessageProcessor extends MessageProcessor { Cluster aCluster = service.getCluster(clusterDataHolder.getClusterId()); if (aCluster != null) { // validate state transition - if (aCluster.isStateTransitionValid(ClusterStatus.Terminating)) { + if (!aCluster.isStateTransitionValid(ClusterStatus.Terminating)) { log.error("Invalid state transfer from " + aCluster.getStatus() + " to " - + ClusterStatus.Terminating + " successfully"); + + ClusterStatus.Terminating); } // for now anyway update the status forcefully aCluster.setStatus(ClusterStatus.Terminating); @@ -133,6 +133,7 @@ public class ApplicationUndeployedMessageProcessor extends MessageProcessor { } } + notifyEventListeners(event); return true; } }
