如何使用 MassTransit.IConsumer<IList> ？预取计数>1

Question

在 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);
                    }
                }
         }

Answer 1

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

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

如何使用 MassTransit.IConsumer<IList> ？预取计数>1

How to Use MassTransit.IConsumer<IList> ? with prefetch count>1

c#

masstransit