如何在MassTransit中配置多个重试策略

using MassTransit;
using MassTransit.RabbitMqTransport;
using MassTransit.RetryPolicy;

public class MessageConsumer : IConsumer<Message>
{
    public async Task Consume(ConsumeContext<Message> context)
    {
        // 处理消息的逻辑代码
    }
}

public class RetryPolicyConfigurator : IConfigureRabbitMqReceiveEndpoint
{
    public void Configure(IRabbitMqReceiveEndpointConfigurator configurator)
    {
        configurator.UseMessageRetry(retryConfigurator =>
        {
            retryConfigurator.Intervals(TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(10), TimeSpan.FromSeconds(30));
            retryConfigurator.Handle<SomeExceptionType>();
            // 添加其他需要重试的异常类型
        });
    }
}

var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    cfg.Host(new Uri("rabbitmq://localhost/"), hostConfigurator =>
    {
        hostConfigurator.Username("guest");
        hostConfigurator.Password("guest");
    });

    cfg.ReceiveEndpoint("message-queue", endpointConfigurator =>
    {
        endpointConfigurator.Consumer<MessageConsumer>();
        endpointConfigurator.ConfigureConsumer<MessageConsumer>(context, consumerConfigurator =>
        {
            consumerConfigurator.UseRetry(Retry.None); // 禁用全局重试策略
        });

        endpointConfigurator.ConfigureConsumeTopology = false;
        endpointConfigurator.ConfigureRabbitMqReceiveEndpoint(new RetryPolicyConfigurator()); // 使用自定义的重试策略
    });
});

bus.Start();