是否有一种方法可以从地铁发送原始消息?

Question

我向rabbitmq发送一些消息"x">

var endpoint = await _bus.GetSendEndpoint(new Uri("exchange:x"));
var message = new CustomType {
accountId = 1
};
await endpoint.Send(message);

我在队列中得到的事件如下所示:

{
"messageId": "x",
"conversationId": "x",
"sourceAddress": "rabbitmq://localhost/x",
"destinationAddress": "rabbitmq://localhost/x",
"messageType": [
"urn:message:x"
],
"message": {
"accountId": 1
},
"sentTime": "x",
"headers": {
"MT-Activity-Id": "x"
},
"host": {
...
}
}

但是我希望队列中的消息是这样的:

{
"accountId": 1   
}

是否有任何方法在masstrtransit发送原始消息到队列?

Answer 1

您可以指定原始JSON消息序列化器，使用:

cfg.UseRawJsonSerializer();

这将发送JSON.NET序列化的消息。