masstransit - 消耗。为了不工作

Question

我知道使用 MassTransit，您可以在消息上使用关联 ID，并且您只能使用具有相同关联 ID 的消息。

我在控制台应用程序中执行了此操作，但它不起作用，即使具有不同的相关 ID，它也会获取所有消息。实际上我的“CorrelationId”属性从未被调用过。

谢谢

Answer 1

您只能将此类型的消费者注册为基于实例的消费者。

x.Subscribe(s => s.Instance(consumer));

并且该实例应该具有 CorrelationId 的固定 Guid。

这确实是很早就投入 MT 的东西，在实践中并没有真正有用，因为 endpoint.SendRequest() 功能更适合请求/响应。对于基于内容的路由，分发器是更好的选择。