Почему пользовательская десериализация MassTransit не работает с конечной точкой подписки служебной шины Azure? ⇐ C#

[Anonymous]

Я использую MassTransit с Azure Service Bus и мой потребитель не получает события, когда тело сообщения использует пользовательский формат JSON . Формат издателя не может быть изменен, потому что он управляется извне. < /P>
MassTransit только обрабатывает событие, когда в сообщении есть структура, в котором он ожидает: < /p>
Событие Обернут в свойство сообщения.
Тип события указан в свойстве EventType. События . Я попытался внедрить пользовательский Deserializer для обработки пользовательского формата, но он, похоже, не применяется. С помощью пользовательского корпуса JSON? ниже приведен пример события, которое не отправляется потребителю:

ниже приведен пример события, которое отправляется потребителю, поскольку в нем есть событие внутри свойства сообщения: < /p>

Сообщение - это простой объект JSON: < /p>
{
"PlanId": "1",
"Description":"test"

}

Вот моя потребительская реализация:
public class ServiceBusEventConsumer : IConsumer
{
private readonly IServiceBusEventProcessorFactory _serviceBusEventProcessorFactory;

public ServiceBusEventConsumer(IServiceBusEventProcessorFactory serviceBusEventProcessorFactory)
{
_serviceBusEventProcessorFactory = serviceBusEventProcessorFactory;
}

public Task Consume(ConsumeContext context)
{
// var strategy = _serviceBusEventProcessorFactory.GetServiceBusEventHandlerStrategy(context.Message.ServiceBusEventType);
// await strategy.HandleEventAsync(context.Message);
return Task.CompletedTask;
}
}

public class EventPlanCreated
{
public string EventId{ get; set; }
public string Description{ get; set; }
}

Вот конфигурация в Program.cs:
builder.Services.AddMassTransit(x =>
{
x.AddConsumer();

x.UsingAzureServiceBus((context, cfg) =>
{
cfg.Host(builder.Configuration["ServiceBusSettings:ConnectionString"]);

// Configure Subscription Endpoint
cfg.SubscriptionEndpoint("tmsuscription", e =>
{
e.ConfigureConsumeTopology = false;
e.ConfigureConsumer(context);

// Use custom deserializer
e.ClearSerialization();
e.UseRawJsonSerializer();
});
});
});



Подробнее здесь: https://stackoverflow.com/questions/793 ... ce-bus-sub