Repository: stratos Updated Branches: refs/heads/4.0.0-grouping c95377ff9 -> dd210b592
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/4.0.0-grouping Commit: dd210b59206a445e8ae3fef8f97f937012dd528c Parents: c95377f Author: Isuru Haththotuwa <[email protected]> Authored: Tue Oct 28 11:05:11 2014 +0530 Committer: Isuru Haththotuwa <[email protected]> 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);
