Я использовал образец, найденный в https://github.com/MassTransit/MassTransit/tree/develop/src/Samples/Sample.AzureFunctions.ServiceBus. Функция корректно выполняется, когда сообщение попадает в очередь, однако код потребления, зарегистрированный следующим, никогда не выполняется ...
cfg.Consumer(() => new SubmitOrderConsumer());
класс потребления
public class SubmitOrderConsumer :
IConsumer<SubmitOrder>
{
public Task Consume(ConsumeContext<SubmitOrder> context)
{
LogContext.Debug?.Log("Processing Order: {OrderNumber}", context.Message.OrderNumber);
context.Publish<OrderReceived>(new
{
context.Message.OrderNumber,
Timestamp = DateTime.UtcNow
});
return context.RespondAsync<OrderAccepted>(new {context.Message.OrderNumber});
}
}
Есть ли что-то еще, чего мне не хватает, это поддерживается в .net Core 3?
Спасибо