阿帕奇骆驼quartz2 cron失火

Question

我在Spring Boot和camel-config.xml文件中使用Apache Camel。我创建了一个每秒运行一次的简单路由，并运行一个类方法：

<camelContext xmlns="http://camel.apache.org/schema/spring" id="myContext" trace="true" streamCache="true" useMDCLogging="true">       
    <route id="testCron">
        <from uri="quartz2://TestCron?cron=0/1 * * * * ?" />
        <to uri="bean:folder.MyClass?method=test" />
    </route>
</camelContext>

package folder;

public class MyClass {

    private static int count = 0;

    public static void test(Exchange exchange) throws Exception {
        count = count + 1;
        System.out.println(count);
    }    

}

我读了很多试图解决这个问题的书。我听到的是吼声：

• 发生的事情叫做“失火”
• 有一个参数允许配置失火说明
• 根据Apache Camel文档，如果使用的是cron表达式，则不能使用trigger.xxx选项（该选项允许配置失火指令）。
• 根据Apache Camel文档，只有当quartz处于集群模式时才会记录失火。
• 您可以将quartz属性配置为禁用群集模式（我不需要它）。

我没有运气的尝试：

null

Answer 1

我无法找到修改失火指令的方法，但我找到了一个解决方案。

我现在停止endpoint，而不是用context.stoproute（routeId）停止路由：

public static void stopRoute(Exchange exchange) throws Exception {

    String beanId = (String) exchange.getIn().getHeader("beanId");
    String routeId = (String) exchange.getIn().getHeader("routeId");

    SpringCamelContext context = (SpringCamelContext) exchange.getContext().getRegistry().lookupByName(beanId);

    for (Route route : context.getRoutes()) {
        if (route.getId().equals(routeId)) {
            route.getEndpoint().stop();
        }
    }

}