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
