MassTransit从外部系统中提取消息

Question

当消息从不同的消息发送源(在本例中为RabbitMQ Client)发送时,MassTransit如何从RabbitMQ中提取消息？

消息共享相同的C#消息合同并序列化为json.

我收到的当前错误是masstransit解析错误...

Answer 1

MassTransit 使用许多约定，如果从非 MassTransit 发布者发布，您可能需要添加到有效负载中的其他详细信息。如果您遇到解析错误，您可能缺少下面的 messageType 信息。

有效负载：

{
  "destinationAddress": "rabbitmq://localhost/<exchange>",
  "headers": {},
  "message": {
    "property": "value"
  },
  "messageType": [    
    "urn:message:<TYPE>",
    "urn:message:<PARENT_TYPE>"
  ],
  "sourceAddress": "rabbitmq://localhost/queue"
}