如何使用MassTransit.IConsumer ?预取计数> 1

问题描述 投票:0回答: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
1个回答
1
投票
© www.soinside.com 2019 - 2024. All rights reserved.