Azure 服务总线 Camel 组件接收控制

问题描述 投票:0回答:1

我们正在尝试从 Camel AMQP 组件迁移到 Camel Azure Service Bus 组件,以用于接收消息的服务。使用 AMQP 组件,我们可以指定 maxConcurrentConsumers 作为控制服务实例可以同时处理多少消息的方法。对于 ASB 组件,不存在此类配置参数。我们可以采用什么机制来控制一次处理的消息数量?或者担心的是:如果组件已经消费并正在处理 50 条消息并且 pod 崩溃了,会发生什么情况?文档指出在交换成功结束之前消息不会被确认,但我持怀疑态度。

我们的学习还很早,到目前为止,我们只创建了一个订阅队列和处理消息的服务。

apache-camel azureservicebus spring-camel
1个回答
0
投票

我不是 asb 专家,但我在以前的公司使用过它,asb 中有两种接收模式 Receive and delete 和 Peek 在这种情况下你应该使用 peek 模式。骆驼有 peekNumMaxMessages 参数和有关 asb 中接收模式的更多详细信息

https://learn.microsoft.com/zh-cn/azure/service-bus-messaging/service-bus-queues-topics-subscriptions

© www.soinside.com 2019 - 2024. All rights reserved.