【发布时间】:2020-07-02 09:36:06
【问题描述】:
我当然知道管理客户端中有一个名为 ActiveMessages 的属性,它提供所有活动消息的计数。但我想知道的是未决消息
var runTimeInfo = await Helpers.ManagementClient.GetSubscriptionRuntimeInfoAsync(topicName,
subscriptionName);
var messageCount = runTimeInfo.MessageCountDetails.ActiveMessageCount;
待定消息是我订阅的任何订阅者尚未收到的消息。
上下文-
想象一个场景,我的订阅者正在接收消息并执行一些长时间运行的操作。现在我已经根据消息数量扩大了基础设施。扩展基础架构的逻辑是每 30 秒运行一次的计时器触发 azure 函数。
问题是,即使我的消息被订阅者接收,活动消息计数并没有减少,这在我扩大基础设施的逻辑中产生了问题。
所以我理想中需要的是 PendingMessageCount,即 ActiveMessageCount - MessagesThatareUnderProcess。
如果您以前遇到过这种情况,请告诉我
【问题讨论】:
标签: azure-functions azureservicebus azure-servicebus-topics