MassTransit вытягивание сообщений из внешней системы

Question

Как MassTransit может выводить сообщения из RabbitMQ, когда сообщения отправляются из другого источника отправки сообщений (в этом случае клиент RabbitMQ)?

Сообщения имеют один и тот же контракт с сообщением C# и сериализуются как json.

Ошибка тока я получаю это masstransit ошибка синтаксического анализа ...

Answer 1

MassTransit использует ряд конвенций и есть дополнительные детали вы, что, вероятно, нужно будет добавить к полезной нагрузке, если публикации из не MassTransit издателя. Если вы получаете ошибку синтаксического анализа, вам, вероятно, не хватает информации типа messageType ниже.

Payload:

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