时间戳

首页 > 解决方案 > MassTransit 重试策略引发 System.NullReferenceException：

.net - MassTransit 重试策略引发 System.NullReferenceException：

问题描述

出于某种原因，我无法按照文档中的示例对我的消费者使用重试，我只是向我的消费者添加了一个简单的 r.Interval<>，但它在构建时失败了......不知道为什么

 services.AddMassTransit(x =>
        {
            x.AddConsumer<SyncConsumer>();
            x.AddConsumer<SyncForcadoConsumer>();
        });
        services.AddSingleton(provider => Bus.Factory.CreateUsingAzureServiceBus(cfg =>
        {
            var host = cfg.Host(
                "Endpoint=sb://" + busName + ".servicebus.windows.net/;" +
                "SharedAccessKeyName=" + keyName + ";" +
                "SharedAccessKey=" + secret,
                z =>
                {
                    TokenProvider
                        .CreateSharedAccessSignatureTokenProvider(keyName, secret);
                });
            cfg.UseExtensionsLogging(provider.GetService<ILoggerFactory>());
            cfg.ReceiveEndpoint(host, "sync-crm-relacionamento",
                e => { e.Consumer<SyncConsumer>(provider); });
            cfg.ReceiveEndpoint(host, "sync-forcado-crm-relacionamento",
                e =>
                {                        
                    e.Consumer<SyncForcadoConsumer>(provider);

                    e.UseMessageRetry(r =>
                    {
                        r.Handle<ArgumentNullException>();

                    });
                });
        }));

但由于某种原因，我收到了这个错误

Unhandled Exception: MassTransit.ConfigurationException: An exception occurred during bus creation ---> System.NullReferenceException: Object reference not set to an instance of an object.
   at MassTransit.PipeConfigurators.ConsumeContextRetryPipeSpecification`2.Apply(IPipeBuilder`1 builder)
   at MassTransit.ConsumePipeSpecifications.MessageConsumePipeSpecification`1.Apply(ISpecificationPipeBuilder`1 builder)
   at MassTransit.ConsumePipeSpecifications.MessageConsumePipeSpecification`1.BuildMessagePipe(IPipe`1 pipe)
   at MassTransit.Builders.ReceiveEndpointBuilder.ConnectConsumePipe[T](IPipe`1 pipe)
   at MassTransit.ConsumeConnectors.ConsumerConnector`1.MassTransit.ConsumeConnectors.IConsumerConnector.ConnectConsumer[TConsumer](IConsumePipeConnector consumePipe, IConsumerFactory`1 consumerFactory, IConsumerSpecification`1 specification)
   at MassTransit.ConsumeConfigurators.ConsumerConfigurator`1.Configure(IReceiveEndpointBuilder builder)

有任何想法吗？

标签： .netmasstransit

解决方案

您需要实际指定重试策略。有效政策包括：

e.UseMessageRetry(r =>
{
    r.Interval(5, 100);

    r.Intervals(100, 500, 1000);

    r.Immediate(2);
});

选择一个，还有其他几个，包括指数和无。

它引发了配置异常，因为您实际上没有配置重试。

重试用法包含在文档中。

推荐阅读