使用Http源引发org/wso2/transport/http/netty/contract/config/ListenerConfiguration错误

Question

使用http源，我尝试将3个参数插入到一个流中，我将使用它作为其他流的输入。

@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);

我在'@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

这在以前是有效的-我能够通过curl命令将数据传递到流。有没有人能帮我弄明白出了什么问题？

我使用的是WSO2SP 4.3.0和siddhi-io-http-1.1.2.jar

Answer 1

WSO2SP 4.3.0不支持siddhi-io-http-1.1.2.jar，请改用WSO2SP 4.4.0，WSO2SP 4.4.0也可以使用当前最新版本的siddhi-io-http-1.2.1 .jar

https://mvnrepository.com/artifact/org.wso2.extension.siddhi.io.http/siddhi-io-http/1.2.1