MassTransit Saga用HandleSaga处理消息遇'envelope'空值错误求助

我尝试通过以下代码处理服务总线上接收的消息：
_receiver.HandleSaga(MyQueue, message, cancellationToken)
但收到错误提示：Value cannot be null. (Parameter 'envelope')

我已创建如下SagaDefinition类：

public class MySagaDefinition : SagaDefinition<MyState>
{
    protected override void ConfigureSaga(IReceiveEndpointConfigurator endpointConfigurator, ISagaConfigurator<MyState> sagaConfigurator, IRegistrationContext context)
    {
        if (endpointConfigurator is IServiceBusReceiveEndpointConfigurator sb)
        {
            sb.RequiresSession = true;
            sb.ConfigureConsumeTopology = false;
            sb.DefaultContentType = new ContentType("application/json");
            sb.ClearSerialization();
            sb.UseRawJsonSerializer();
        }
    }
}

但错误仍未解决。另外，我使用的AddMassTransitForAzureFunctions配置中没有UseRawJsonSerializer()方法，求解决思路。

• 排查message参数有效性：错误提示的envelope为空，通常是因为传入的message未被正确封装为MassTransit要求的消息信封。手动调用HandleSaga时，需确保message是符合格式的消息对象，或者手动构建包含消息的信封结构。
• 适配Azure Functions的序列化配置：AddMassTransitForAzureFunctions针对Functions场景做了封装，无法直接使用UseRawJsonSerializer，可通过配置JSON序列化器替代：

  builder.Services.AddMassTransitForAzureFunctions(cfg =>
  {
      cfg.SetKebabCaseEndpointNameFormatter();
      cfg.AddSaga<MyState>()
          .Endpoint(e => e.Name = MyQueue)
          .DefinitionType(typeof(MySagaDefinition));
      
      // 配置JSON序列化/反序列化规则
      cfg.ConfigureJsonSerializer(options =>
      {
          // 根据需求调整序列化配置，比如保留原始属性名
          options.PropertyNamingPolicy = null;
          return options;
      });
      cfg.ConfigureJsonDeserializer(options =>
      {
          options.PropertyNamingPolicy = null;
          return options;
      });
  });
  

• 验证Session配置一致性：Saga启用了RequiresSession = true，需确保Azure Service Bus队列已开启会话支持，同时发送消息时指定了合法的会话ID，否则消息无法被Saga正确接收处理。
• 优先使用内置触发器处理消息：在Azure Functions场景下，不建议手动调用HandleSaga，推荐使用MassTransit的ServiceBusTrigger触发器，让框架自动处理消息封装、Saga调度等流程，减少手动处理的出错概率，示例如下：

  [FunctionName("SagaMessageHandler")]
  public async Task Run(
      [ServiceBusTrigger(MyQueue, Connection = "ServiceBusConnection")] Message message,
      ILogger log)
  {
      // 由MassTransit自动绑定Saga处理逻辑
  }
  

内容的提问来源于stack exchange，提问作者Michiel Stienaers