MassTransit 和 Azure 服务总线：所有已创建订阅的 EnableDeadLetteringOnMessageExpiration

Question

我们将 MassTransit 配置为以这种方式使用 Azure 服务总线：

                mtConfig.UsingAzureServiceBus((context, busConfig) =>
                {
                    busConfig.Host(new HostSettings
                    {
                        ServiceUri = new Uri(xxx),
                        TokenProvider = TokenProvider.CreateManagedIdentityTokenProvider()
                    });

                    busConfig.ConfigureJsonSerializer(ConfigureJsonSerialization);
                    busConfig.ConfigureJsonDeserializer(ConfigureJsonSerialization);
                    busConfig.ConfigureEndpoints(context);
                });

我们如何设置例如MassTransit 自动创建的所有订阅的订阅属性，例如 EnableDeadLetteringOnMessageExpiration？

谢谢， 彼得

更新

我已经尝试过（EnableDeadLetteringOnMessageExpiration），但是 Azure 服务总线中的订阅没有启用死信选项（我们首先删除了所有主题和订阅，因此它们是新创建的）：

            mtConfig.UsingAzureServiceBus((context, busConfig) =>
            {
                busConfig.Host(new HostSettings
                {
                    ServiceUri = new Uri(xxx),
                    TokenProvider = TokenProvider.CreateManagedIdentityTokenProvider()
                });

               busConfig.EnableDeadLetteringOnMessageExpiration = true;

               busConfig.ConfigureJsonSerializer(ConfigureJsonSerialization);
               busConfig.ConfigureJsonDeserializer(ConfigureJsonSerialization);
               busConfig.ConfigureEndpoints(context);
            });

Answer 1

您可以创建一个实现IConfigureReceiveEndpoint 的类（请参阅the docs），并在该函数中，对配置器进行模式匹配以查看它是否是 Azure 服务总线并设置属性。在容器中注册后，MassTransit 将针对每个端点运行该类。

class ConfigureMyEndpoint :
    IConfigureReceiveEndpoint
{
    public void Configure(string name, IReceiveEndpointConfigurator configurator)
    {
        if(configurator is IServiceBusReceiveEndpointConfigurator sb)
        {
            sb.EnableDeadLetteringOnMessageExpiration = true;
        }
    }
}