如何确保apache camel一次从AWS SQS中选择一条消息?

d5vmydt9  于 2023-03-08  发布在  Apache
关注(0)|答案(1)|浏览(150)

最近我调试了一个应用程序,发现ApacheCamel使用者一次选择两条消息并处理它们,我调试后发现ApacheCamel创建了两个线程,尽管它被指定为只有一个线程-thread(1,1)就像创建路线一样。我认为CamelConext正在创建一个线程(默认)和一个线程用于路由(只有一个路由)。有什么方法可以禁用默认线程吗?我的最终目标是配置一个消费者,一次从AWS SQS中挑选和处理一条消息。
我将CamelContext的defaultTHread最小/最大线程池更新为1。它不起作用。

qij5mzcb

qij5mzcb1#

不确定你是否已经尝试过,但是根据文档(https://camel.apache.org/components/3.20.x/aws2-sqs-component.html),你可以在你的消费者上定义“maxMessagesPerPoll”作为选项。这设置了每次轮询的最大消息数,因此一次将处理多少条消息。

相关问题