Hi, For the event builder to be active, the stream to which that builder is publishing must be defined. Also, for WSO2 events, the incoming stream definition also must be defined.
You can go to the inactive event builders section in management console where you can find a short message specifying the reason why the event builder is inactive. Usually a similar message will be printed to console as well. HTH, Lasantha On 10 January 2014 00:22, Chamila Wijayarathna <[email protected]> wrote: > Hi all, > After changing "*org.wso2.log_analyzer.out*" stream I am not getting that > exception. Thank you for helping. > I added few eventBuilders and they have been shown as Inactive builders, > what is the reason for that? > > Thank you. > > > On Thu, Jan 9, 2014 at 11:54 PM, Lasantha Fernando <[email protected]>wrote: > >> Hi Chamila, >> >> Looking at the snippet pasted here, I cannot find any obvious issue in >> your code. Can you point to the complete code for your client so I can dig >> deeper? >> >> What are the values you pass for STREAM_NAME1 and VERSION1? >> >> Also, it seems the error is coming at data-bridge level before the event >> hits the event builder. You can verify this by enabling tracing for your >> InputEventAdaptor and EventBuilder, where you can see the actual incoming >> event. Looking at the actual event received might help you find where the >> issue is. >> >> Also as Manula has suggested, please check the *org.wso2.log_analyzer.out >> stream *stream as well. >> >> Thanks, >> Lasantha >> >> >> On 9 January 2014 23:43, Manula Chathurika Thantriwatte <[email protected] >> > wrote: >> >>> Hi, >>> >>> >>> >>> >>> *Seems that org.wso2.log_analyzer.out stream have different stream >>> definition. Please look into that. Thanks !* >>> >>> >>> On Thu, Jan 9, 2014 at 11:07 PM, Chamila Wijayarathna >>> <[email protected]>wrote: >>> >>>> hello all, >>>> I am trying to send some events to CEP in WSO2Event Format. >>>> In my publisher I create a stream as follows. >>>> >>>> *streamId1 = dataPublisher.defineStream("{" +* >>>> * " 'name':'" + STREAM_NAME1 + "'," +* >>>> * " 'version':'" + VERSION1 + "'," +* >>>> * " 'nickName': 'Statistics'," +* >>>> * " 'description': 'Service statistics'," +* >>>> * " 'metaData':[" +* >>>> >>>> * " {'name':'referer','type':'STRING'}" +* >>>> * " ]," +* >>>> * " 'payloadData':[" +* >>>> * " {'name':'SrcIp','type':'STRING'}," +* >>>> * " {'name':'DestIp','type':'STRING'}," +* >>>> * " {'name':'size','type':'STRING'}," +* >>>> * " {'name':'timestamp','type':'STRING'}" +* >>>> * " ]" +* >>>> * "}");* >>>> >>>> Then I published some events using above stream as follows. >>>> >>>> Ob*ject[] meta = new Object[]{* >>>> * "MetaData"* >>>> * };* >>>> *Object[] payload = new Object[]{* >>>> * SrcIp,* >>>> * DestIp,* >>>> * size, // Unix timeStamp* >>>> * "600" * >>>> * };* >>>> *Event statisticsEvent = new Event(streamId1, >>>> System.currentTimeMillis(),* >>>> * meta, correlation, >>>> payload);* >>>> * dataPublisher.publish(statisticsEvent);* >>>> >>>> I also created an event builder at CEP for above stream. It has the >>>> following source view. >>>> >>>> *<?xml version="1.0" encoding="UTF-8"?>* >>>> *<eventBuilder name="logg" statistics="disable" trace="disable" >>>> xmlns="http://wso2.org/carbon/eventbuilder >>>> <http://wso2.org/carbon/eventbuilder>">* >>>> * <from eventAdaptorName="WSO2EventAdaptor" >>>> eventAdaptorType="wso2event">* >>>> * <property >>>> name="stream">org.wso2.log_analyzer.netflow.info1</property>* >>>> * <property name="version">1.0.0</property>* >>>> * </from>* >>>> * <mapping customMapping="enable" type="wso2event">* >>>> * <property>* >>>> * <from dataType="meta" name="referer"/>* >>>> * <to name="ref" type="string"/>* >>>> * </property>* >>>> * <property>* >>>> * <from dataType="payload" name="SrcIp"/>* >>>> * <to name="src" type="string"/>* >>>> * </property>* >>>> * <property>* >>>> * <from dataType="payload" name="DestIp"/>* >>>> * <to name="dest" type="string"/>* >>>> * </property>* >>>> * <property>* >>>> * <from dataType="payload" name="size"/>* >>>> * <to name="size" type="string"/>* >>>> * </property>* >>>> * <property>* >>>> * <from dataType="payload" name="timestamp"/>* >>>> * <to name="timestamp" type="string"/>* >>>> * </property>* >>>> * </mapping>* >>>> * <to streamName="org.wso2.log_analyzer.out" version="1.0.0"/>* >>>> *</eventBuilder>* >>>> >>>> When I run the publisher and send the events to CEP I'm getting >>>> following exeption for each event. >>>> >>>> * ERROR - {QueueWorker} Wrongly formatted event sent for carbon.super* >>>> *org.wso2.carbon.databridge.core.exception.EventConversionException: >>>> Error when converting MetaData of event bundle with events 36* >>>> * at >>>> org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.createEventList(ThriftEventConverter.java:126)* >>>> * at >>>> org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.toEventList(ThriftEventConverter.java:88)* >>>> * at >>>> org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:72)* >>>> * at >>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)* >>>> * at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)* >>>> * at java.util.concurrent.FutureTask.run(FutureTask.java:166)* >>>> * at >>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)* >>>> * at >>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)* >>>> * at java.lang.Thread.run(Thread.java:724)* >>>> *Caused by: >>>> org.wso2.carbon.databridge.core.exception.EventConversionException: No >>>> StreamDefinition for streamId MetaData present in cache * >>>> * at >>>> org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.createEventList(ThriftEventConverter.java:112)* >>>> * ... 8 more* >>>> >>>> What is the problem here? How can I solve this? >>>> >>>> >>>> -- >>>> *Chamila Wijayarathna* >>>> Engineering Intern, >>>> WSO2 Inc. >>>> >>>> >>>> _______________________________________________ >>>> Dev mailing list >>>> [email protected] >>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>> >>>> >>> >>> >>> -- >>> Regards, >>> Manula Chathurika Thantriwatte >>> Software Engineer >>> WSO2 Inc. : http://wso2.com >>> lean . enterprise . middleware >>> >>> email : [email protected] / [email protected] >>> phone : +94 772492511 >>> blog : http://manulachathurika.blogspot.com/ >>> >>> >>> >>> >>> _______________________________________________ >>> Dev mailing list >>> [email protected] >>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>> >>> >> >> >> -- >> *Lasantha Fernando* >> Software Engineer - Data Technologies Team >> WSO2 Inc. http://wso2.com >> >> email: [email protected] >> mobile: (+94) 71 5247551 >> > > > > -- > *Chamila Wijayarathna* > Engineering Intern, > WSO2 Inc. > > -- *Lasantha Fernando* Software Engineer - Data Technologies Team WSO2 Inc. http://wso2.com email: [email protected] mobile: (+94) 71 5247551
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
