首页 > 解决方案 > 如何使用 MassTransit.IConsumer? 预取计数>1

问题描述

在 MassTransit 中,如何通过设置 prefetchCount>1 来消费 IList 事件?,DataSynchronizationConsumer 正在消费由 busconrol.Publish(new DataSynchronizationMessage) 发布的事件

    public class DataSynchronizationConsumer : IConsumer<IList<DataSynchronizationMessage>>
         {
               public Task Consume(ConsumeContext<IList<DataSynchronizationMessage>> context)
               {
                    return Task.Run(() =>
                    {
                       Transfer(context.Message);
                    }
                }
         }

标签: c#masstransit

解决方案


您应该使用 MassTransit 的批处理功能。没有IList消息的方法。

https://masstransit-project.com/advanced/batching.html


推荐阅读