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