Lahiru, I think this is not the correct fix. Manula should know better. I think the correct fix is to change the event stream definition. On Dec 17, 2013 6:55 AM, <[email protected]> wrote:
> Updated Branches: > refs/heads/master 1d320e592 -> ef07f2b14 > > > Fixing STRATOS-299 > > > Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo > Commit: > http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/ef07f2b1 > Tree: > http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/ef07f2b1 > Diff: > http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/ef07f2b1 > > Branch: refs/heads/master > Commit: ef07f2b1437e0b380f77409bbf9b2154e413c2a3 > Parents: 1d320e5 > Author: Lahiru Sandaruwan <[email protected]> > Authored: Tue Dec 17 06:58:44 2013 +0530 > Committer: Lahiru Sandaruwan <[email protected]> > Committed: Tue Dec 17 06:58:44 2013 +0530 > > ---------------------------------------------------------------------- > .../cep/artifacts/event-formatters/FaultMessageEventFormatter.xml | 2 +- > 1 file changed, 1 insertion(+), 1 deletion(-) > ---------------------------------------------------------------------- > > > > http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/ef07f2b1/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml > ---------------------------------------------------------------------- > diff --git > a/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml > b/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml > index c594b5a..9d91cef 100644 > --- > a/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml > +++ > b/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml > @@ -3,7 +3,7 @@ > statistics="disable" trace="enable" xmlns=" > http://wso2.org/carbon/eventformatter"> > <from streamName="fault_message" version="1.0.0"/> > <mapping customMapping="enable" type="json"> > - > > <inline>{"member_fault":{"cluster_id":"{{cluster_id}}","network_partition_id":"{{network_partition_id}}","member_id":"{{member_id}}"}}</inline> > + > > <inline>{"member_fault":{"cluster_id":"{{cluster_id}}","partition_id":"{{partition_id}}","member_id":"{{member_id}}"}}</inline> > </mapping> > <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms"> > <property > name="transport.jms.Destination">summarized-health-stats</property> > >
