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 2014/10/30 05:13:44 UTC
[20/50] [abbrv] git commit: correcting wrong state transition in
GroupTerminatingProcessor
correcting wrong state transition in GroupTerminatingProcessor
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/dd210b59
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/dd210b59
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/dd210b59
Branch: refs/heads/docker-grouping-merge
Commit: dd210b59206a445e8ae3fef8f97f937012dd528c
Parents: c95377f
Author: Isuru Haththotuwa <is...@apache.org>
Authored: Tue Oct 28 11:05:11 2014 +0530
Committer: Isuru Haththotuwa <is...@apache.org>
Committed: Tue Oct 28 11:05:11 2014 +0530
----------------------------------------------------------------------
.../message/processor/topology/GroupTerminatingProcessor.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/dd210b59/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/GroupTerminatingProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/GroupTerminatingProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/GroupTerminatingProcessor.java
index 210279c..ecf6873 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/GroupTerminatingProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/GroupTerminatingProcessor.java
@@ -93,8 +93,8 @@ public class GroupTerminatingProcessor extends MessageProcessor {
}
} else {
// Apply changes to the topology
- if (!group.isStateTransitionValid(GroupStatus.Active)) {
- log.error("Invalid State Transition from " + group.getStatus() + " to " + GroupStatus.Active);
+ if (!group.isStateTransitionValid(GroupStatus.Terminating)) {
+ log.error("Invalid State Transition from " + group.getStatus() + " to " + GroupStatus.Terminating);
}
group.setStatus(GroupStatus.Terminating);