httpsiddhiwso2-streaming-integrator

Using Http source throws org/wso2/transport/http/netty/contract/config/ListenerConfiguration error


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


Solution

  • 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