Updated Branches: refs/heads/master d73fa919c -> 00a32e1e3
adding health stat message processor chain Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/00a32e1e Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/00a32e1e Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/00a32e1e Branch: refs/heads/master Commit: 00a32e1e3e1d973aee23160e070c143ecd33e207 Parents: d73fa91 Author: Lahiru Sandaruwan <[email protected]> Authored: Sat Dec 21 08:50:36 2013 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Sat Dec 21 08:50:36 2013 +0530 ---------------------------------------------------------------------- .../stat/AverageLoadAverageEventListener.java | 7 +- .../AverageMemoryConsumptionEventListener.java | 7 +- .../AverageRequestsInFlightEventListener.java | 7 +- .../GradientOfLoadAverageEventListener.java | 7 +- ...radientOfMemoryConsumptionEventListener.java | 7 +- ...GradientOfRequestsInFlightEventListener.java | 7 +- .../MemberAverageLoadAverageEventListener.java | 7 +- ...erAverageMemoryConsumptionEventListener.java | 7 +- .../health/stat/MemberFaultEventListener.java | 7 +- ...emberGradientOfLoadAverageEventListener.java | 22 +--- ...radientOfMemoryConsumptionEventListener.java | 7 +- ...ondDerivativeOfLoadAverageEventListener.java | 7 +- ...ivativeOfMemoryConsumptionEventListener.java | 7 +- ...ondDerivativeOfLoadAverageEventListener.java | 7 +- ...ivativeOfMemoryConsumptionEventListener.java | 7 +- ...rivativeOfRequestsInFlightEventListener.java | 7 +- .../stat/HealthStatMessageProcessorChain.java | 106 +++++++++++++++++++ 17 files changed, 200 insertions(+), 33 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageLoadAverageEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageLoadAverageEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageLoadAverageEventListener.java index c65ee0b..c043589 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageLoadAverageEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageLoadAverageEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Average of Load average event listener */ -public class AverageLoadAverageEventListener extends Event { +public class AverageLoadAverageEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageMemoryConsumptionEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageMemoryConsumptionEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageMemoryConsumptionEventListener.java index b5d904e..6eaa166 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageMemoryConsumptionEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageMemoryConsumptionEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Memory consumption event listener */ -public class AverageMemoryConsumptionEventListener extends Event { +public class AverageMemoryConsumptionEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageRequestsInFlightEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageRequestsInFlightEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageRequestsInFlightEventListener.java index e707d70..9fd7144 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageRequestsInFlightEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/AverageRequestsInFlightEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Average of requests in flight event listener */ -public class AverageRequestsInFlightEventListener extends Event { +public class AverageRequestsInFlightEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfLoadAverageEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfLoadAverageEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfLoadAverageEventListener.java index de21abd..aeddc71 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfLoadAverageEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfLoadAverageEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Gradient of Load average event listener */ -public class GradientOfLoadAverageEventListener extends Event { +public class GradientOfLoadAverageEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfMemoryConsumptionEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfMemoryConsumptionEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfMemoryConsumptionEventListener.java index 9bc0305..d70aff7 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfMemoryConsumptionEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfMemoryConsumptionEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Memory consumption event listener */ -public class GradientOfMemoryConsumptionEventListener extends Event { +public class GradientOfMemoryConsumptionEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfRequestsInFlightEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfRequestsInFlightEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfRequestsInFlightEventListener.java index c4824a5..dd25481 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfRequestsInFlightEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/GradientOfRequestsInFlightEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Gradient of requests in flight event listener */ -public class GradientOfRequestsInFlightEventListener extends Event { +public class GradientOfRequestsInFlightEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageLoadAverageEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageLoadAverageEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageLoadAverageEventListener.java index 8f10aa5..a154ad8 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageLoadAverageEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageLoadAverageEventListener.java @@ -20,10 +20,15 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Average of Load average event listener */ -public class MemberAverageLoadAverageEventListener extends Event { +public class MemberAverageLoadAverageEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageMemoryConsumptionEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageMemoryConsumptionEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageMemoryConsumptionEventListener.java index 68580c3..8424a1b 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageMemoryConsumptionEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberAverageMemoryConsumptionEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Average of memory consumption event listener */ -public class MemberAverageMemoryConsumptionEventListener extends Event { +public class MemberAverageMemoryConsumptionEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberFaultEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberFaultEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberFaultEventListener.java index d8fc9f4..7e43e35 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberFaultEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberFaultEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Member fault event listener */ -public class MemberFaultEventListener extends Event { +public class MemberFaultEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfLoadAverageEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfLoadAverageEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfLoadAverageEventListener.java index 46b8891..baabe84 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfLoadAverageEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfLoadAverageEventListener.java @@ -20,29 +20,15 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Gradient of Load average event listener */ -public class MemberGradientOfLoadAverageEventListener extends Event { +public class MemberGradientOfLoadAverageEventListener extends EventListener { - private String memberId; - private float value; + @Override + protected void onEvent(Event event) { - - public String getMemberId() { - return memberId; - } - - public void setMemberId(String memberId) { - this.memberId = memberId; - } - - public float getValue() { - return value; - } - - public void setValue(float value) { - this.value = value; } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfMemoryConsumptionEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfMemoryConsumptionEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfMemoryConsumptionEventListener.java index 7d67fe7..ee48322 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfMemoryConsumptionEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberGradientOfMemoryConsumptionEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Gradient of memory consumption event listener */ -public class MemberGradientOfMemoryConsumptionEventListener extends Event { +public class MemberGradientOfMemoryConsumptionEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfLoadAverageEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfLoadAverageEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfLoadAverageEventListener.java index ec2b4b7..dba4504 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfLoadAverageEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfLoadAverageEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Second derivative of Load average event listener */ -public class MemberSecondDerivativeOfLoadAverageEventListener extends Event { +public class MemberSecondDerivativeOfLoadAverageEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfMemoryConsumptionEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfMemoryConsumptionEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfMemoryConsumptionEventListener.java index d854e52..5e6fc2a 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfMemoryConsumptionEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/MemberSecondDerivativeOfMemoryConsumptionEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Second derivative of memory consumption event listener */ -public class MemberSecondDerivativeOfMemoryConsumptionEventListener extends Event { +public class MemberSecondDerivativeOfMemoryConsumptionEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfLoadAverageEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfLoadAverageEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfLoadAverageEventListener.java index a7a5817..6db5b2f 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfLoadAverageEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfLoadAverageEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Second derivative of Load average event listener */ -public class SecondDerivativeOfLoadAverageEventListener extends Event { +public class SecondDerivativeOfLoadAverageEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfMemoryConsumptionEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfMemoryConsumptionEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfMemoryConsumptionEventListener.java index 1266cb0..0dc8c18 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfMemoryConsumptionEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfMemoryConsumptionEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Second derivative of memory consumption event listener event listener */ -public class SecondDerivativeOfMemoryConsumptionEventListener extends Event { +public class SecondDerivativeOfMemoryConsumptionEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfRequestsInFlightEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfRequestsInFlightEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfRequestsInFlightEventListener.java index 6518bf5..2c1e60d 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfRequestsInFlightEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/health/stat/SecondDerivativeOfRequestsInFlightEventListener.java @@ -20,9 +20,14 @@ package org.apache.stratos.messaging.listener.health.stat; import org.apache.stratos.messaging.event.Event; +import org.apache.stratos.messaging.listener.EventListener; /** * Second derivative of requests in flight event listener */ -public class SecondDerivativeOfRequestsInFlightEventListener extends Event { +public class SecondDerivativeOfRequestsInFlightEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/00a32e1e/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/HealthStatMessageProcessorChain.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/HealthStatMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/HealthStatMessageProcessorChain.java new file mode 100644 index 0000000..60c7d1e --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/HealthStatMessageProcessorChain.java @@ -0,0 +1,106 @@ +package org.apache.stratos.messaging.message.processor.health.stat; + +import org.apache.stratos.messaging.listener.EventListener; +import org.apache.stratos.messaging.listener.health.stat.*; +import org.apache.stratos.messaging.message.processor.MessageProcessorChain; + +/** + * Defines default health stat message processor chain. + */ +public class HealthStatMessageProcessorChain extends MessageProcessorChain { + private AverageLoadAverageMessageProcessor averageLoadAverageMessageProcessor; + private AverageMemoryConsumptionMessageProcessor averageMemoryConsumptionMessageProcessor; + private AverageRequestsInFlightMessageProcessor averageRequestsInFlightMessageProcessor; + private GradientOfLoadAverageMessageProcessor gradientOfLoadAverageMessageProcessor; + private GradientOfMemoryConsumptionMessageProcessor gradientOfMemoryConsumptionMessageProcessor; + private GradientOfRequestsInFlightMessageProcessor gradientOfRequestsInFlightMessageProcessor; + private MemberAverageLoadAverageMessageProcessor memberAverageLoadAverageMessageProcessor; + private MemberAverageMemoryConsumptionMessageProcessor memberAverageMemoryConsumptionMessageProcessor; + private MemberFaultMessageProcessor memberFaultMessageProcessor; + private MemberGradientOfLoadAverageMessageProcessor memberGradientOfLoadAverageMessageProcessor; + private MemberGradientOfMemoryConsumptionMessageProcessor memberGradientOfMemoryConsumptionMessageProcessor; + private MemberSecondDerivativeOfLoadAverageMessageProcessor memberSecondDerivativeOfLoadAverageMessageProcessor; + private MemberSecondDerivativeOfMemoryConsumptionMessageProcessor memberSecondDerivativeOfMemoryConsumptionMessageProcessor; + private SecondDerivativeOfLoadAverageMessageProcessor secondDerivativeOfLoadAverageMessageProcessor; + private SecondDerivativeOfMemoryConsumptionMessageProcessor secondDerivativeOfMemoryConsumptionMessageProcessor; + private SecondDerivativeOfRequestsInFlightMessageProcessor secondDerivativeOfRequestsInFlightMessageProcessor; + + + protected void initialize() { + averageLoadAverageMessageProcessor = new AverageLoadAverageMessageProcessor(); + add(averageLoadAverageMessageProcessor); + averageMemoryConsumptionMessageProcessor = new AverageMemoryConsumptionMessageProcessor(); + add(averageMemoryConsumptionMessageProcessor); + averageRequestsInFlightMessageProcessor = new AverageRequestsInFlightMessageProcessor(); + add(averageRequestsInFlightMessageProcessor); + gradientOfLoadAverageMessageProcessor = new GradientOfLoadAverageMessageProcessor(); + add(gradientOfLoadAverageMessageProcessor); + gradientOfMemoryConsumptionMessageProcessor = new GradientOfMemoryConsumptionMessageProcessor(); + add(gradientOfMemoryConsumptionMessageProcessor); + gradientOfRequestsInFlightMessageProcessor = new GradientOfRequestsInFlightMessageProcessor(); + add(gradientOfRequestsInFlightMessageProcessor); + memberAverageLoadAverageMessageProcessor = new MemberAverageLoadAverageMessageProcessor(); + add(memberAverageLoadAverageMessageProcessor); + memberAverageMemoryConsumptionMessageProcessor = new MemberAverageMemoryConsumptionMessageProcessor(); + add(memberAverageMemoryConsumptionMessageProcessor); + memberFaultMessageProcessor = new MemberFaultMessageProcessor(); + add(memberFaultMessageProcessor); + memberGradientOfLoadAverageMessageProcessor = new MemberGradientOfLoadAverageMessageProcessor(); + add(memberGradientOfLoadAverageMessageProcessor); + memberGradientOfMemoryConsumptionMessageProcessor = new MemberGradientOfMemoryConsumptionMessageProcessor(); + add(memberGradientOfMemoryConsumptionMessageProcessor); + memberSecondDerivativeOfLoadAverageMessageProcessor = new MemberSecondDerivativeOfLoadAverageMessageProcessor(); + add(memberSecondDerivativeOfLoadAverageMessageProcessor); + memberSecondDerivativeOfMemoryConsumptionMessageProcessor = new MemberSecondDerivativeOfMemoryConsumptionMessageProcessor(); + add(memberSecondDerivativeOfMemoryConsumptionMessageProcessor); + secondDerivativeOfLoadAverageMessageProcessor = new SecondDerivativeOfLoadAverageMessageProcessor(); + add(secondDerivativeOfLoadAverageMessageProcessor); + secondDerivativeOfMemoryConsumptionMessageProcessor = new SecondDerivativeOfMemoryConsumptionMessageProcessor(); + add(secondDerivativeOfMemoryConsumptionMessageProcessor); + secondDerivativeOfRequestsInFlightMessageProcessor = new SecondDerivativeOfRequestsInFlightMessageProcessor(); + add(secondDerivativeOfRequestsInFlightMessageProcessor); + + } + + public void addEventListener(EventListener eventListener) { + + if (eventListener instanceof AverageLoadAverageEventListener) { + averageLoadAverageMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof AverageMemoryConsumptionEventListener) { + averageMemoryConsumptionMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof AverageRequestsInFlightEventListener) { + averageRequestsInFlightMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof GradientOfLoadAverageEventListener) { + gradientOfLoadAverageMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof GradientOfMemoryConsumptionEventListener) { + gradientOfMemoryConsumptionMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof GradientOfRequestsInFlightEventListener) { + gradientOfRequestsInFlightMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberAverageLoadAverageEventListener) { + memberAverageLoadAverageMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberAverageMemoryConsumptionEventListener) { + memberAverageMemoryConsumptionMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberFaultEventListener) { + memberFaultMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberGradientOfLoadAverageEventListener) { + memberGradientOfLoadAverageMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberGradientOfMemoryConsumptionEventListener) { + memberGradientOfMemoryConsumptionMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberSecondDerivativeOfLoadAverageEventListener) { + memberSecondDerivativeOfLoadAverageMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof MemberSecondDerivativeOfMemoryConsumptionEventListener) { + memberSecondDerivativeOfMemoryConsumptionMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof SecondDerivativeOfLoadAverageEventListener) { + secondDerivativeOfLoadAverageMessageProcessor.addEventListener(eventListener); + } else if (eventListener instanceof SecondDerivativeOfMemoryConsumptionEventListener) { + secondDerivativeOfMemoryConsumptionMessageProcessor.addEventListener(eventListener); + + }else if (eventListener instanceof SecondDerivativeOfRequestsInFlightEventListener) { + secondDerivativeOfRequestsInFlightMessageProcessor.addEventListener(eventListener); + + } + else { + throw new RuntimeException("Unknown event listener"); + } + } +}
