Repository: incubator-stratos Updated Branches: refs/heads/master 8b6ce5ced -> eed199ba1
adding listener for member maintenance mode and adding integers for the state Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/326c3541 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/326c3541 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/326c3541 Branch: refs/heads/master Commit: 326c3541c13834f3e64847b22cf3137519114559 Parents: 4851b4f Author: rekathiru <[email protected]> Authored: Fri Feb 21 18:53:14 2014 +0530 Committer: rekathiru <[email protected]> Committed: Fri Feb 21 18:53:14 2014 +0530 ---------------------------------------------------------------------- .../messaging/domain/topology/MemberStatus.java | 19 ++++++++++++++++++- .../topology/TopologyMessageProcessorChain.java | 3 +++ 2 files changed, 21 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/326c3541/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/MemberStatus.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/MemberStatus.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/MemberStatus.java index e3008a3..508e65b 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/MemberStatus.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/MemberStatus.java @@ -26,6 +26,23 @@ import javax.xml.bind.annotation.XmlRootElement; */ @XmlRootElement public enum MemberStatus { - Created, Starting, Activated, Suspended, ReadyToShutDown, ShuttingDown, Terminated, In_Maintenance + Created(1), + Starting(2), + Activated(3), + In_Maintenance(4), + ReadyToShutDown(5), + Terminated(6), + Suspended(0), + ShuttingDown(0); + + private int code; + + private MemberStatus(int code) { + this.code = code; + } + + public int getCode() { + return code; + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/326c3541/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java index 7ba2e1d..ad18c0c 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/TopologyMessageProcessorChain.java @@ -110,6 +110,9 @@ public class TopologyMessageProcessorChain extends MessageProcessorChain { serviceCreatedMessageProcessor.addEventListener(eventListener); } else if (eventListener instanceof ServiceRemovedEventListener) { serviceRemovedMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberMaintenanceListener) { + memberMaintenanceModeProcessor.addEventListener(eventListener); + } else { throw new RuntimeException("Unknown event listener"); }
