You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by la...@apache.org on 2013/12/21 04:16:07 UTC
git commit: adding health stat message processor chain
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 <la...@apache.org>
Authored: Sat Dec 21 08:50:36 2013 +0530
Committer: Lahiru Sandaruwan <la...@apache.org>
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");
+ }
+ }
+}