阿帕奇骆驼：轮询后访问路由

Question

我使用Camel JPAendpoint来轮询数据库，并将数据复制到第二个数据库。为了不重复轮询，我打算保存复制数据的最高ID，并且只轮询ID高于该ID的数据。

为了节省一些数据库写入，我希望在当前轮询/复制运行结束后写回最高ID，而不是针对每个数据元素。我可以访问骆驼路线类中的元素（及其ID）：

    private Long startId = 0L;
    private Long lastId = 0L;

    from("jpa://Data").routeId("dataRoute")
        .onCompletion().onCompleteOnly().process(ex -> {
            if (lastId > startId) {
                startId = lastId;
                logger.info("New highest ID: {}", startId);
            }
        }).end()
        .process(ex -> {
            Data data = ex.getIn().getBody(Data.class);
            lastId = data.getId();
            NewData newData = (NewData) convertData(data);
            ex.getMessage().setBody(newData);
        }).to("jpa://NewData")

现在我想在当前轮询结束后保存startId。为此，我用自己的自定义方法重写了PollingConsumerPollStrategy，在这里我想访问commit方法中的lastId（在当前轮询完成后，它会在我想要的时候执行）。

但是，我无法访问那里的路由。我尝试通过路由ID：

    @Override
    public void commit(Consumer consumer, Endpoint endpoint, int polledMessages) {
        var route = (MyRoute) endpoint.getCamelContext().getRoute("dataRoute");
        var lastId = route.getLastId();
        log.debug("LastID: {}", lastId);
    }

但是，我收到了一个类强制转换异常：默认路由到MyRoad。是关于将ID交给我的路由吗？

Answer 1

我会做得有点不同。

除了使用 RouteBuilder 实例变量来存储 startId 和 lastId 之外，您还可以将这些值作为当前 CamelContext 的 GlobalOptions（基本上是键值对的映射）放置。

通过这种方式，您可以通过以下方式轻松获取它们的价值：

public void commit(Consumer consumer, Endpoint endpoint, int polledMessages) {
    String lastId = endpoint.getCamelContext().getGlobalOption​("lastId"); 
}

它（理论上）也是一个更好的实现，因为它还支持潜在的并发执行，因为 id 是为上下文中运行的所有实例共享的。