c# - 如何使用 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);
}
}
}
解决方案
您应该使用 MassTransit 的批处理功能。没有IList
消息的方法。
推荐阅读
- google-cloud-platform - 在 google composer 中安装 hadoopy
- c# - IEnumerator 或 IEnumerable 中的“产量”?
- spring-boot - 带有或不带有 Web/Rest 的 Spring Boot 2 JPA 异常翻译
- android - Android : Gridview 切割项目的边缘
- assembly - 在 RISC-V 上执行函数调用时出现非法指令
- json - 从 JSON 解码信息时出现颤振问题
- c# - FFMPEG 将 .mpg 流式传输到 Windows 管道并在 C# 中显示视频
- python - Python和sqlite3:删除多行
- bash - POSIX sh 问题(printf 和 'read -n')
- javascript - Jquery onmouseover 函数在第一次悬停时未触发