如何每隔几分钟与非轮询使用者运行一次Apache Camel路由

Question

我有一个定制的Apache Camel组件，它由一个从DefaultConsumer扩展而来的Consumer和没有Producer组成。

我有一个Spring Boot应用程序，与其他几个骆驼路线，都工作得很好。

JacksonDataFormat enrichedAuditLogEntryFormat = new JacksonDataFormat(EnrichedAuditLogEntry.class);

from("alfaudit://http://acs.local:8080?username=" + user + "&password=" + password)
        .routeId("alfrescoAuditLogToElastic")
        .bean("alfAuditLogEntryEnricher")
        .marshal(enrichedAuditLogEntryFormat)
        .setHeader("indexId", header(AlfAuditConsumer.AUDIT_LOG_ENTRY_ID))
        .to("elasticsearch-rest://elasticsearch?operation=Index&indexName=" + AUDIT_LOG_INDEX + "&indexType=" + AUDIT_LOG_TYPE);

from("quartz2://fetchaudit?cron=0+0/5+*+*+*+?")
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                CamelContext context = exchange.getContext();
                context.startRoute("alfrescoAuditLogToElastic");
            }
        });

这在第一次工作，但当下一次触发作业时，它会尝试启动已经运行的路由。

我希望避免修改自定义组件以从DefaultScheduledPollConsumer扩展，因为它并不总是按计划使用。但是，如果这是解决这个问题的最好方法，我对此持开放态度。

Answer 1

恐怕我对你们的定制组件一无所知。但是如果它能够作为生产者和消费者使用，你可能会尝试这样的方法。请注意，作为生产者，如果需要，您可以决定忽略整个消息。

//trigger every 60 seconds
from("timer:timerName?period=60000")
  .routeId("alfrescoAuditLogToElastic")
  .to("alfaudit://http://acs.local:8080?username=" + user + "&password=" + password)
  .bean("alfAuditLogEntryEnricher")
  ...