Repository: stratos Updated Branches: refs/heads/master a4e473ae7 -> 813e0ca0f
fixing cep extension Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/00f50d6d Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/00f50d6d Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/00f50d6d Branch: refs/heads/master Commit: 00f50d6d4f446a209e1d381515016399662d3e40 Parents: 4f2c1b7 Author: reka <[email protected]> Authored: Sun Nov 30 15:06:18 2014 +0530 Committer: reka <[email protected]> Committed: Sun Nov 30 15:48:46 2014 +0530 ---------------------------------------------------------------------- .../cep/extension/FaultHandlingWindowProcessor.java | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/00f50d6d/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 0c7766d..70d8b32 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 @@ -23,15 +23,7 @@ import org.apache.log4j.Logger; import org.apache.stratos.messaging.broker.publish.EventPublisher; import org.apache.stratos.messaging.broker.publish.EventPublisherPool; import org.apache.stratos.messaging.domain.topology.*; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.event.health.stat.MemberFaultEvent; -import org.apache.stratos.messaging.event.topology.CompleteTopologyEvent; -import org.apache.stratos.messaging.event.topology.MemberActivatedEvent; -import org.apache.stratos.messaging.event.topology.MemberTerminatedEvent; -import org.apache.stratos.messaging.listener.topology.CompleteTopologyEventListener; -import org.apache.stratos.messaging.listener.topology.MemberActivatedEventListener; -import org.apache.stratos.messaging.listener.topology.MemberTerminatedEventListener; -import org.apache.stratos.messaging.message.receiver.topology.TopologyEventReceiver; import org.apache.stratos.messaging.message.receiver.topology.TopologyManager; import org.apache.stratos.messaging.util.Util; import org.wso2.siddhi.core.config.SiddhiContext; @@ -214,7 +206,7 @@ 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(), 0); + member.getPartitionId(), member.getNetworkPartitionId(), 0); memberFaultEventMessageMap.put("message", memberFaultEvent); healthStatPublisher.publish(MemberFaultEventMap, true);
