如何清除 C# (Microsoft.Azure.ServiceBus v3+) 中的 Azure ServiceBus 主题订阅?

字节开发

我如何(在 C# 中)使用 Microsoft.Azure.ServiceBus 包(版本 3+)清除 Azure 服务总线的主题订阅?

我知道 SO问题但是所选的答案似乎在 SubscriptionClient 上使用了 ReceiveBatch(),它似乎不再可用(?)。SubscriptionClient 现在似乎真的只有 RegisterMessageHandler() 来处理消息,但是使用这意味着我的客户永远不会知道订阅何时实际上是空的。

有没有一种干净的方法可以使用 C# 清除主题?

米哈伊尔·希尔科夫

您可以MessageReceiver以类似的方式使用类:

IMessageReceiver messageReceiver = new MessageReceiver(
    namespaceConnectionString,
    EntityNameHelper.FormatSubscriptionPath(topicName, subscriptionName),
    ReceiveMode.ReceiveAndDelete);

int batchSize = 100;
var operationTimeout = TimeSpan.FromSeconds(3);

do
{
    var messages = await messageReceiver.ReceiveAsync(batchSize, operationTimeout);
    if (messages == null || messages.Count == 0) // Returns null if no message is found
    {
       break;
    }
}
while (true);

请注意,现在只有异步 API 可用。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

如何使用Microsoft.Azure.ServiceBus在订阅上创建MessageReceiver

来自分类Dev

C#Azure:如何从Microsoft.Azure.ServiceBus.Message读取正文?

来自分类Dev

Azure ServiceBus队列超时

来自分类Dev

Azure ServiceBus AutoRenewTimeout

来自分类Dev

我可以查看Azure ServiceBus主题订阅上当前启用的筛选器吗?

来自分类Dev

Azure ServiceBus命名空间-从旧订阅中删除并在新订阅中创建

来自分类Dev

将Sqlfilter应用于Azure Function中的ServiceBus主题触发器?

来自分类Dev

延迟接收有关Azure ServiceBus主题的消息

来自分类Dev

如何使用python azure sdk为ServiceBus订阅生成SAS令牌?

来自分类Dev

完全忽略了azure servicebus maxConcurrentCalls

来自分类Dev

查找Azure Servicebus消息的来源

来自分类Dev

Azure Servicebus队列消息处理

来自分类Dev

Node.js SDK中的Azure ServiceBus SAS

来自分类Dev

将消息移动到Azure Servicebus中的'deadletter'

来自分类Dev

从 ServiceBus 触发的 azure 函数中检索 IoT Hub Twin

来自分类Dev

如何从.NET通过Azure Servicebus发送javax.jms.TextMessage

来自分类Dev

Microsoft.Azure.ServiceBus:提供的锁无效。锁已过期,或者消息已从队列中删除

来自分类Dev

我在哪里设置Azure ServiceBus超时

来自分类Dev

无法在树莓派中导入Azure ServiceBus

来自分类Dev

Azure ServiceBus令牌已过期

来自分类Dev

Azure ServiceBus SubscriptionClient.EndReceive()返回null

来自分类Dev

发送或侦听Azure ServiceBus时出错

来自分类Dev

Azure ServiceBus OnMessage是否阻止调用?

来自分类Dev

Azure ApiApp-收听ServiceBus消息

来自分类Dev

ServiceBus 的 Azure ARM 模板:无法引用自身

来自分类Dev

Docker NodeJS Azure ServiceBus 服务锁定超时

来自分类Dev

将 Microsoft.Azure.ServiceBus 消息发送到 BizTalk 2013 WCF-Custom

来自分类Dev

Azure ServiceBus订阅客户端<->服务器通信(接收和响应)

来自分类Dev

在使用node.js特定延迟后从Azure ServiceBus主题发送消息

Related 相关文章

  1. 1

    如何使用Microsoft.Azure.ServiceBus在订阅上创建MessageReceiver

  2. 2

    C#Azure:如何从Microsoft.Azure.ServiceBus.Message读取正文?

  3. 3

    Azure ServiceBus队列超时

  4. 4

    Azure ServiceBus AutoRenewTimeout

  5. 5

    我可以查看Azure ServiceBus主题订阅上当前启用的筛选器吗?

  6. 6

    Azure ServiceBus命名空间-从旧订阅中删除并在新订阅中创建

  7. 7

    将Sqlfilter应用于Azure Function中的ServiceBus主题触发器?

  8. 8

    延迟接收有关Azure ServiceBus主题的消息

  9. 9

    如何使用python azure sdk为ServiceBus订阅生成SAS令牌?

  10. 10

    完全忽略了azure servicebus maxConcurrentCalls

  11. 11

    查找Azure Servicebus消息的来源

  12. 12

    Azure Servicebus队列消息处理

  13. 13

    Node.js SDK中的Azure ServiceBus SAS

  14. 14

    将消息移动到Azure Servicebus中的'deadletter'

  15. 15

    从 ServiceBus 触发的 azure 函数中检索 IoT Hub Twin

  16. 16

    如何从.NET通过Azure Servicebus发送javax.jms.TextMessage

  17. 17

    Microsoft.Azure.ServiceBus:提供的锁无效。锁已过期,或者消息已从队列中删除

  18. 18

    我在哪里设置Azure ServiceBus超时

  19. 19

    无法在树莓派中导入Azure ServiceBus

  20. 20

    Azure ServiceBus令牌已过期

  21. 21

    Azure ServiceBus SubscriptionClient.EndReceive()返回null

  22. 22

    发送或侦听Azure ServiceBus时出错

  23. 23

    Azure ServiceBus OnMessage是否阻止调用?

  24. 24

    Azure ApiApp-收听ServiceBus消息

  25. 25

    ServiceBus 的 Azure ARM 模板:无法引用自身

  26. 26

    Docker NodeJS Azure ServiceBus 服务锁定超时

  27. 27

    将 Microsoft.Azure.ServiceBus 消息发送到 BizTalk 2013 WCF-Custom

  28. 28

    Azure ServiceBus订阅客户端<->服务器通信(接收和响应)

  29. 29

    在使用node.js特定延迟后从Azure ServiceBus主题发送消息

热门标签

归档