Hi Suho, Mohan has already added a note to the doc. Thanks Mohan for adding to docs.. :-)
On 10 January 2014 08:05, Sriskandarajah Suhothayan <[email protected]> wrote: > Lasantha please add this to the docs too. > > Suho > On Jan 10, 2014 1:15 AM, "Lasantha Fernando" <[email protected]> wrote: > >> 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 >> >> -- *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
