地下铁路及天青服务巴士定期重试

Question

我们的公共交通/Azure服务总线设置运行得很好，但还有一个功能我们很想使用，但似乎不起作用-计划重新交付。

以下是启动中的代码：

busFactoryConfig.UseServiceBusMessageScheduler();
    
busFactoryConfig.SubscriptionEndpoint(Constants.SubscriptionName, Constants.TopicName, configurator =>
                    {
                        configurator.UseScheduledRedelivery(r => r.Intervals(TimeSpan.FromMinutes(5), TimeSpan.FromMinutes(15), TimeSpan.FromMinutes(30)));
                        configurator.UseMessageRetry(r =>
                        {
                            r.Immediate(2);
                            r.Ignore<InvalidCastException>(); //we don't want to retry here, the message content is invalid
                        });

这似乎与文档很匹配。尽管文档似乎只涉及RabbitMQ。

但是，当这实际触发时，会引发masstransit异常，并且重新交付不起作用。这是在使用。NET核心3.1、MassTransit 7.0.1和Azure服务总线主题。

错误（故意抛出以触发重试）：

MassTransit.TransportException: **ADDRESS** => The message delivery could not be rescheduled
 ---> System.AggregateException: One or more errors occurred. (The specified resource description is invalid. TrackingId:cda5544e-90e4-4818-97f9-4de3ee55aaad_G46, SystemTracker:**TOPIC**, Timestamp:2020-07-22T13:22:23) (BAM! <- MY ERROR)
 ---> Microsoft.Azure.ServiceBus.ServiceBusException: The specified resource description is invalid. TrackingId:cda5544e-90e4-4818-97f9-4de3ee55aaad_G46, SystemTracker:**TOPIC**, Timestamp:2020-07-22T13:22:23
 ---> System.ArgumentException: The specified resource description is invalid. TrackingId:cda5544e-90e4-4818-97f9-4de3ee55aaad_G46, SystemTracker:**TOPIC**, Timestamp:2020-07-22T13:22:23

我尝试了不同的设置，更类似于文档：

busFactoryConfig.UseMessageScheduler(uri); //Uri is my sb endpoint, minus Endpoint=

这给我们带来了一个不同的错误：

InvalidAudience: The authorization header contains a token with a wrong audience.

快速阅读会发现这与Azure如何使用密钥有关，而且可能已经过时。然而，这就是我用来成功连接到总线的同一个URI——我所做的只是删除Endpoint=以便在构造新URI（）时它是一个有效的URI。

Azure服务总线的计划重新交付是否与MT一起工作？配置中是否缺少某些内容？

任何帮助都将不胜感激。

Answer 1

正如Chris在上面回答的那样-SubscriptionEndpoints不受支持，您必须使用ReceiveEndpoint。这对我很有用：

busFactoryConfig.UseServiceBusMessageScheduler();

busFactoryConfig.ReceiveEndpoint(Constants.SubscriptionName, configurator =>
                    {
                        configurator.UseScheduledRedelivery(r => r.Intervals(TimeSpan.FromMinutes(1), TimeSpan.FromMinutes(2), TimeSpan.FromMinutes(3)));
                        configurator.UseMessageRetry(r =>
                        {
                            r.Immediate(2);
                            r.Ignore<InvalidCastException>(); //we don't want to retry here, the message content is invalid
                        });

                        configurator.ConfigureConsumer<MyConsumer>(context);
                    }

Answer 2

无法使用订阅终结点进行重新交付。如果要使用重传，我建议使用常规ReceiveEndpoint（消息将从主题转发到队列，队列由MassTransit使用消费者消息类型配置）。

订阅endpoint特定于ASB，通常仅在您有想要直接订阅的现有主题时使用。