Using http source, I'm trying to insert 3 parameters into a stream, which I will use as an input to other streams.
@App:name("SiddhiSample")
@App:description("Sample http")
@source(type='http', receiver.url='http://0.0.0.0:8008/event', @map(type = 'json', @attributes(a='$.a', b='$.c', c='$.c')))
define stream InputStream(a string, b string, c string);
I'm getting this error at the line '@source' -
Caused by: org.wso2.siddhi.core.exception.SiddhiAppCreationException: Error on 'SiddhiSample' @ Line: 5. Position: 143, near '@source(type='http', receiver.url='http://0.0.0.0:8008/event', @map(type = 'json', @attributes(a='$.a', b='$.b', c='$.c')))'. org/wso2/transport/http/netty/contract/config/ListenerConfiguration
at org.wso2.siddhi.core.util.ExceptionUtil.populateQueryContext(ExceptionUtil.java:43)
at org.wso2.siddhi.core.util.parser.helper.DefinitionParserHelper.addEventSource(DefinitionParserHelper.java:370)
at org.wso2.siddhi.core.util.SiddhiAppRuntimeBuilder.defineStream(SiddhiAppRuntimeBuilder.java:114)
at org.wso2.siddhi.core.util.parser.SiddhiAppParser.defineStreamDefinitions(SiddhiAppParser.java:307)
at org.wso2.siddhi.core.util.parser.SiddhiAppParser.parse(SiddhiAppParser.java:223)
at org.wso2.siddhi.core.SiddhiManager.createSiddhiAppRuntime(SiddhiManager.java:65)
at org.wso2.siddhi.core.SiddhiManager.createSiddhiAppRuntime(SiddhiManager.java:74)
at org.wso2.carbon.stream.processor.core.internal.StreamProcessorService.deploySiddhiApp(StreamProcessorService.java:100)
at org.wso2.carbon.stream.processor.core.internal.StreamProcessorDeployer.deploySiddhiQLFile(StreamProcessorDeployer.java:93)
... 14 more
Caused by: java.lang.NoClassDefFoundError: org/wso2/transport/http/netty/contract/config/ListenerConfiguration
at org.wso2.extension.siddhi.io.http.source.util.HttpSourceUtil.getListenerConfiguration(HttpSourceUtil.java:177)
at org.wso2.extension.siddhi.io.http.source.HttpSource.initSource(HttpSource.java:478)
at org.wso2.extension.siddhi.io.http.source.HttpSource.init(HttpSource.java:415)
at org.wso2.siddhi.core.stream.input.source.Source.init(Source.java:69)
at org.wso2.siddhi.core.util.parser.helper.DefinitionParserHelper.addEventSource(DefinitionParserHelper.java:365)
... 21 more
This was working previously - I was able to pass data to the stream via curl commands. Can someone help me understand what's wrong?
I'm using WSO2SP 4.3.0 and siddhi-io-http-1.1.2.jar
WSO2SP 4.3.0 is not supporting siddhi-io-http-1.1.2.jar, please use WSO2SP 4.4.0 instead, and WSO2SP 4.4.0 will also work with the current latest version of siddhi-io-http-1.2.1 .jar
https://mvnrepository.com/artifact/org.wso2.extension.siddhi.io.http/siddhi-io-http/1.2.1