camel jpa组件maxMessagesPerPoll不工作

Question

我对camel-jpa组件中的“maxMessagesPerPoll”的理解是，当我设置“maxMessagesPerPoll=4”时，每个投票将获取4条记录。但不是每个投票相同的4条记录。我应该得到下4套记录。

但是当我把参数设置为4时，我总是得到相同的前4条记录。如何获得每次投票的下一组后续记录。

这背后的想法——我想分批处理REORD，而不是同时处理所有数据。

只是想有可滚动的-有点。

如何做到这一点？

Answer 1

在一行中设置一个标志，并在消费后将其设置为true，然后将该条件放入JPA查询中。

eg:- from MyEntity where flag = false;

骆驼会帮你的。您只需要在实体中添加一个方法。

    @Consumed
    public void updateRecord() {
        setFlag(true);
    }

下次将获取所有新行。

Answer 2

您需要将之前处理过的行标记为已处理，方法是删除它们，或更新某些列以指示已处理，因此下次轮询不会拾取它们。