使用RabbitMQ在NServiceBus中设置自动删除和独占属性

问题描述 投票:0回答:1

有谁知道如何在NServiceBus中为RabbitMq队列设置autodelete和exclusive?

我尝试了以下但它不起作用:

        protected override void OnConfigurationStarting(EndpointConfiguration configuration, ContainerBuilder builder,
        Assembly[] assemblies, TransportExtensions<RabbitMQTransport> transport)
    {
        transport.GetSettings().Set("exclusive", true);
        transport.GetSettings().Set("autodelete", true);

        configuration.PurgeOnStartup(true);
        configuration.DisableFeature<TimeoutManager>();
        configuration.LimitMessageProcessingConcurrencyTo(40);
        configuration.UsePersistence<InMemoryPersistence, StorageType.GatewayDeduplication>();
        configuration.UsePersistence<InMemoryPersistence, StorageType.Subscriptions>();

        transport.UseConventionalRoutingTopology();
        transport.ConnectionString(EndpointSettings.BusConnectionString);

        var recoverability = configuration.Recoverability();

        recoverability.Delayed(x =>
        {
            x.NumberOfRetries(0);
        });

        recoverability.Immediate(x =>
        {
            x.NumberOfRetries(0);
        });

        _bootstrapperWithMessaging.OnConfigurationStarting(configuration, builder, assemblies);
    }
c# rabbitmq nservicebus
1个回答
0
投票

NServiceBus RabbitMQ传输不支持这些设置。

© www.soinside.com 2019 - 2024. All rights reserved.