我有如下所示的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();
这里有两个单元测试用例,它们显示了SupervisingRouteController的用法。SupervisingRouteControllerTest.javaSupervisingRouteControllerRestartTest.java
这些可能有助于理解其用法。