Updated Branches: refs/heads/master f40a5e1c9 -> 0225801ac
Adding missing processor changes for most frequent first order is defined in default Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/0225801a Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/0225801a Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/0225801a Branch: refs/heads/master Commit: 0225801acabf369a0631361a735ba8648d4b00b8 Parents: f40a5e1 Author: Lahiru Sandaruwan <[email protected]> Authored: Thu Jan 2 13:52:45 2014 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Thu Jan 2 13:52:45 2014 +0530 ---------------------------------------------------------------------- .../stat/HealthStatMessageProcessorChain.java | 52 ++++++++++---------- 1 file changed, 27 insertions(+), 25 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/0225801a/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 index bd89def..19f5a53 100644 --- 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 @@ -8,63 +8,65 @@ 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 SecondDerivativeOfLoadAverageMessageProcessor secondDerivativeOfLoadAverageMessageProcessor; private SecondDerivativeOfMemoryConsumptionMessageProcessor secondDerivativeOfMemoryConsumptionMessageProcessor; private SecondDerivativeOfRequestsInFlightMessageProcessor secondDerivativeOfRequestsInFlightMessageProcessor; - private MemberAverageLoadAverageMessageProcessor memberAverageLoadAverageMessageProcessor; private MemberAverageMemoryConsumptionMessageProcessor memberAverageMemoryConsumptionMessageProcessor; - private MemberGradientOfLoadAverageMessageProcessor memberGradientOfLoadAverageMessageProcessor; private MemberGradientOfMemoryConsumptionMessageProcessor memberGradientOfMemoryConsumptionMessageProcessor; - private MemberSecondDerivativeOfLoadAverageMessageProcessor memberSecondDerivativeOfLoadAverageMessageProcessor; private MemberSecondDerivativeOfMemoryConsumptionMessageProcessor memberSecondDerivativeOfMemoryConsumptionMessageProcessor; private MemberFaultMessageProcessor memberFaultMessageProcessor; 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); + + //Most frequent first order is defined in default 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); + + memberAverageMemoryConsumptionMessageProcessor = new MemberAverageMemoryConsumptionMessageProcessor(); + add(memberAverageMemoryConsumptionMessageProcessor); + memberGradientOfMemoryConsumptionMessageProcessor = new MemberGradientOfMemoryConsumptionMessageProcessor(); + add(memberGradientOfMemoryConsumptionMessageProcessor); memberSecondDerivativeOfMemoryConsumptionMessageProcessor = new MemberSecondDerivativeOfMemoryConsumptionMessageProcessor(); add(memberSecondDerivativeOfMemoryConsumptionMessageProcessor); + + averageRequestsInFlightMessageProcessor = new AverageRequestsInFlightMessageProcessor(); + add(averageRequestsInFlightMessageProcessor); + gradientOfRequestsInFlightMessageProcessor = new GradientOfRequestsInFlightMessageProcessor(); + add(gradientOfRequestsInFlightMessageProcessor); + secondDerivativeOfRequestsInFlightMessageProcessor = new SecondDerivativeOfRequestsInFlightMessageProcessor(); + add(secondDerivativeOfRequestsInFlightMessageProcessor); + + averageLoadAverageMessageProcessor = new AverageLoadAverageMessageProcessor(); + add(averageLoadAverageMessageProcessor); + gradientOfLoadAverageMessageProcessor = new GradientOfLoadAverageMessageProcessor(); + add(gradientOfLoadAverageMessageProcessor); secondDerivativeOfLoadAverageMessageProcessor = new SecondDerivativeOfLoadAverageMessageProcessor(); add(secondDerivativeOfLoadAverageMessageProcessor); + + averageMemoryConsumptionMessageProcessor = new AverageMemoryConsumptionMessageProcessor(); + add(averageMemoryConsumptionMessageProcessor); + gradientOfMemoryConsumptionMessageProcessor = new GradientOfMemoryConsumptionMessageProcessor(); + add(gradientOfMemoryConsumptionMessageProcessor); secondDerivativeOfMemoryConsumptionMessageProcessor = new SecondDerivativeOfMemoryConsumptionMessageProcessor(); add(secondDerivativeOfMemoryConsumptionMessageProcessor); - secondDerivativeOfRequestsInFlightMessageProcessor = new SecondDerivativeOfRequestsInFlightMessageProcessor(); - add(secondDerivativeOfRequestsInFlightMessageProcessor); + memberFaultMessageProcessor = new MemberFaultMessageProcessor(); + add(memberFaultMessageProcessor); } public void addEventListener(EventListener eventListener) {
