Repository: stratos Updated Branches: refs/heads/4.1.0-test d2ebdabbc -> 91b1af197
Fixing member fault event parameter order in fault handling window processor Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/91b1af19 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/91b1af19 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/91b1af19 Branch: refs/heads/4.1.0-test Commit: 91b1af197e9db7d366b55e33c726af4a440ed9a7 Parents: d2ebdab Author: Imesh Gunaratne <[email protected]> Authored: Tue Dec 9 12:57:03 2014 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Tue Dec 9 12:57:03 2014 +0530 ---------------------------------------------------------------------- .../stratos/cep/extension/FaultHandlingWindowProcessor.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/91b1af19/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java ---------------------------------------------------------------------- diff --git a/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java b/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java index 8bfcb2c..0f17693 100644 --- a/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java +++ b/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java @@ -209,8 +209,9 @@ public class FaultHandlingWindowProcessor extends WindowProcessor implements Run } log.info("Publishing member fault event for [member-id] " + memberId); - MemberFaultEvent memberFaultEvent = new MemberFaultEvent(member.getClusterId(), member.getInstanceId(), member.getMemberId(), - member.getPartitionId(), member.getNetworkPartitionId(), 0); + MemberFaultEvent memberFaultEvent = new MemberFaultEvent(member.getClusterId(), member.getMemberId(), + member.getPartitionId(), member.getInstanceId(), + member.getNetworkPartitionId(), 0); memberFaultEventMessageMap.put("message", memberFaultEvent); healthStatPublisher.publish(MemberFaultEventMap, true);
