Repository: stratos Updated Branches: refs/heads/master 4d7491f15 -> 93f3636ab
Update messaging component pom version and mqtt related API calls in CEP 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/93f3636a Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/93f3636a Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/93f3636a Branch: refs/heads/master Commit: 93f3636ab29742230db87b3de232f0af21f50e78 Parents: 4d7491f Author: Akila Perera <[email protected]> Authored: Wed Oct 1 09:36:17 2014 +0530 Committer: Akila Perera <[email protected]> Committed: Wed Oct 1 09:36:56 2014 +0530 ---------------------------------------------------------------------- extensions/cep/stratos-cep-extension/pom.xml | 2 +- .../stratos/cep/extension/FaultHandlingWindowProcessor.java | 4 +--- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/93f3636a/extensions/cep/stratos-cep-extension/pom.xml ---------------------------------------------------------------------- diff --git a/extensions/cep/stratos-cep-extension/pom.xml b/extensions/cep/stratos-cep-extension/pom.xml index 2d58bc5..6a76014 100644 --- a/extensions/cep/stratos-cep-extension/pom.xml +++ b/extensions/cep/stratos-cep-extension/pom.xml @@ -49,7 +49,7 @@ <dependency> <groupId>org.apache.stratos</groupId> <artifactId>org.apache.stratos.messaging</artifactId> - <version>4.0.0-SNAPSHOT</version> + <version>4.1.0-SNAPSHOT</version> </dependency> </dependencies> http://git-wip-us.apache.org/repos/asf/stratos/blob/93f3636a/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 b1830d8..34333ad 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 @@ -203,9 +203,7 @@ public class FaultHandlingWindowProcessor extends WindowProcessor implements Run MemberFaultEvent memberFaultEvent = new MemberFaultEvent(member.getClusterId(), member.getMemberId(), member.getPartitionId(), 0); memberFaultEventMessageMap.put("message", memberFaultEvent); - Properties headers = new Properties(); - headers.put(Constants.EVENT_CLASS_NAME, memberFaultEvent.getClass().getName()); - healthStatPublisher.publish(MemberFaultEventMap, headers, true); + healthStatPublisher.publish(MemberFaultEventMap, true); }
