Hi Vasanth,
It seems, you have to pass the className as the header parameter as per
yout MSF4J service implementation. Please set the className as the header
in the http sink and tryout.
Thanks,
Mohan
On Thu, Oct 11, 2018 at 10:52 AM, Vasanthan Sivalingam <vasant...@wso2.com>
wrote:
> Hi SP team,
>
> Currently i have written a siddhi application,
>
>
>
>
>
>
>
>
>
>
>
> *@App:name('TestMinimumHA')@source(type='http', receiver.url=
> 'http://192.168.48.26:9006/endpoints
> <http://192.168.48.26:9006/endpoints>', topic='symbol',
> @map(type='xml'))define stream FooStream (symbol string, price float, class
> string);@sink(type='http',
> publisher.url='http://192.168.48.254:8080/testresults
> <http://192.168.48.254:8080/testresults>',
> method='{{method}}',headers="'content-type:text/plain'",@map(type='json'))define
> stream BarStream (message string, value float, method string, headers
> string);from FooStream#window.length(5)select symbol as message, max(price)
> as value, 'POST' as method, class as headersinsert into BarStream;from
> BarStream#log("Events: ")insert into OutputStream;*
>
> through postman i am passing an event with POST
> http://192.168.48.26:9006/endpoints -H content-type="plain/text"
> with body
> <events>
> <event>
> <symbol>First</symbol>
> <price>20f</price>
> <class>cclassName:com.sp.test.StateSync</class>
> </event>
> </events>
>
> in the server side i am getting a response :
> [2018-10-11 03:57:10,666] INFO {org.wso2.siddhi.core.query.
> processor.stream.LogStreamProcessor} - TestMinimumHA: Events: ,
> StreamEvent{ timestamp=1539230230663, beforeWindowData=null,
> onAfterWindowData=null, outputData=[First, 20.0, POST,
> *cclassName:com.sp.test.StateSync*], type=CURRENT, next=null}
> [2018-10-11 03:57:13,387] ERROR {org.wso2.carbon.stream.
> processor.core.persistence.PersistenceManager}
>
> I am running a MSF4J in host: 192.168.48.254, port:8080,in the MSF4J side
> i am getting a response as below.
>
> 2018-10-11 03:57:11 INFO VerifyTest:144 - POST invoked
> 2018-10-11 03:57:11 INFO VerifyTest:145 - Content-Type=application/json
> 2018-10-11 03:57:11 INFO VerifyTest:145 - HTTP_METHOD=POST
> 2018-10-11 03:57:11 INFO VerifyTest:145 - connection=keep-alive
> 2018-10-11 03:57:11 INFO VerifyTest:145 - forwarded=by=192.168.48.26;
> proto=http
> 2018-10-11 03:57:11 INFO VerifyTest:145 - content-length=103
> 2018-10-11 03:57:11 INFO VerifyTest:153 - adding event under new test case.
> 2018-10-11 03:57:11 INFO VerifyTest:158 - *TestCaseName: null*
>
> Can i have some suggestions on how to set the TestCaseName as , *TestCaseName:
> com.sp.test.StateSync*
>
> Thanks,
> Vasanth
>
--
*V. Mohanadarshan* | Technical Lead | WSO2 Inc. <http://www.wso2.com/> |
(M) 94-771117673 | (E) mo...@wso2.com |
GET INTEGRATION AGILE
Integration Agility for Digitally Driven Business
_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
