java siddhi无法使用siddhi从rabbitmq检索事件消息
public static void main(String[] args) {
String siddhiApp = "@App:name('TestExecutionPlan') "
+ "define stream FooStream (teste string); "
+ "@info(name = 'query1') "
+ "@source(type ='rabbitmq', "
+ "uri = 'amqp://test:test@192.168.99.100:5672', "
+ "exchange.name = 'amq.topic', "
+ "exchange.type = 'topic', "
+ "routing.key= '#', "
+ "queue.name = 'siddhi-queue', "
+ "@map(type='text')) "
+ "Define stream BarStream (test string); "
+ "from FooStream select test insert into BarStream; ";
SiddhiManager siddhiManager = new SiddhiManager();
SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(siddhiApp);
siddhiAppRuntime.start();
siddhiAppRuntime.addCallback("FooStream", new StreamCallback() {
public void receive(Event[] event) {
EventPrinter.print(event);
}
});
}
此代码无法从rabbitmq检索事件消息
我可以看到连接和进入rabbitmq仪表板的通道,所有发布到exchange的消息都会传递到其他绑定队列
# 1 楼答案
抱歉,伙计们,我发现问题了
log4j。未配置属性
# 2 楼答案
你需要回调“BarStream”,这是源代码。您可以尝试以下示例
参考Siddhi查询Quide:Siddhi-source