- 综合排序
- 最热优先
- 最新优先
- 来自专栏痴者工良
开源一款功能强大的 .NET 消息队列通讯模型框架 Maomi.MQ
Qos 是通过特性来配置的： [Consumer("ConsumerWeb", Qos = 1)] 可以通过调高 Qos 值，让程序在可以并发消息，提高并发量。 [Consumer("ConsumerWeb_dead_2", Expiration = 6000, DeadQueue = "ConsumerWeb_dead_queue_2")] public class EmptyDeadConsumer : EmptyConsumer<DeadEvent> { } // ConsumerWeb_dead 消费失败的消息会被此消费者消费。 message) => Task.FromResult(false); } // ConsumerWeb_dead 消费失败的消息会被此消费者消费。 [Consumer("ConsumerWeb_dead_2", Expiration = 6000, DeadQueue = "ConsumerWeb_dead_queue_2")] public class
82210编辑于 2024-06-14 - 来自专栏DotNet NB && CloudNative
Maomi.MQ 2.0 | 功能强大的 .NET 消息队列通讯模型框架
本篇示例可参考 ConsumerWeb 项目。 [Consumer("consumerWeb_dead", Expiration = 6000, DeadRoutingKey = "consumerWeb_dead_queue")] publicclassEmptyDeadConsumer :EmptyConsumer<DeadEvent> { } // ConsumerWeb_dead 消费失败的消息会被此消费者消费。 [Consumer("ConsumerWeb_dead_2", Expiration = 6000, DeadQueue = "ConsumerWeb_dead_queue_2")] publicclassEmptyDeadConsumer :EmptyConsumer<DeadEvent> { } // ConsumerWeb_dead 消费失败的消息会被此消费者消费。
2.1K00编辑于 2025-04-06 - 来自专栏痴者工良
Maomi.MQ 2.0 | 功能强大的 .NET 消息队列通讯模型框架
本篇示例可参考 ConsumerWeb 项目。 Qos 是通过特性来配置的： [Consumer("ConsumerWeb", Qos = 1)] 可以通过调高 Qos 值，让程序在可以并发消息，提高并发量。 [Consumer("consumerWeb_dead", Expiration = 6000, DeadRoutingKey = "consumerWeb_dead_queue")] public class EmptyDeadConsumer : EmptyConsumer<DeadEvent> { } // ConsumerWeb_dead 消费失败的消息会被此消费者消费。 [Consumer("ConsumerWeb_dead_2", Expiration = 6000, DeadQueue = "ConsumerWeb_dead_queue_2")] public class
1.7K10编辑于 2025-03-26
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号