http - 使用 Http 源抛出 org/wso2/transport/http/netty/contract/config/ListenerConfiguration 错误
问题描述
使用 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
解决方案
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 。罐
https://mvnrepository.com/artifact/org.wso2.extension.siddhi.io.http/siddhi-io-http/1.2.1
推荐阅读
- upload - 新的谷歌网站 - 如何上传 pdf
- c# - 在多行字符串中使用枚举名称将每个字符串行与枚举的整数值相关联。有没有更好的办法?
- python - Django restframework Error binding parameter
- macos - macOS - [NSValue valueWithCGAffineTransform:]
- angular - 角度测试随机失败
- python - 为什么在 elif 语句中使用输入时会出现语法错误?
- c# - DI/CI Dependency/Constructor injection,怎么知道有哪些对象可用?
- java - 如何保持实例变量的名称与构造函数参数的名称相同?
- qt - 从 ipc fifo 文件描述符读取缓冲区时未初始化 QDataStream
- mvel - 如何使用 j-easy 简单规则编写条件以查找集合中的任何匹配值