SupervisingRouteController文档

问题描述 投票:0回答:1

我有如下所示的MQTT路线

from("paho:mytopic?brokerUrl=tcp://0.0.0.0:1883&clientId=ipc)
.routeId("myroute")
.to("log:my?showAll=true&multiline=true");

仅在代理可用时启动,此后如果与代理失去连接,它将很好地处理并恢复。

但是我担心的是,如果经纪人不可用,我如何才能第一次开始?

我在Google上搜索并了解到“ SupervisingRouteController”在这方面可能会有所帮助,但是没有可用的文档。通过一些尝试,我达到了这一点,但是由于没有可用的文档,我还能做些什么

final Main main = new Main();
main.addRouteBuilder(new MyMqttRoute());
SupervisingRouteController controller = main.getCamelContexts().get(0).getRouteController().unwrap(SupervisingRouteController.class);
main.run();
apache-camel paho
1个回答
0
投票

这里有两个单元测试用例,它们显示了SupervisingRouteController的用法。SupervisingRouteControllerTest.javaSupervisingRouteControllerRestartTest.java

这些可能有助于理解其用法。

© www.soinside.com 2019 - 2024. All rights reserved.