Установите автоматическое удаление и эксклюзивные свойства в NServiceBus с RabbitMQ - PullRequest
Новая
       21

Установите автоматическое удаление и эксклюзивные свойства в NServiceBus с RabbitMQ

0 голосов
/ 25 апреля 2019

Кто-нибудь знает, как установить autodelete и exclusive в NServiceBus для очередей RabbitMq?

Я пробовал следующее, но оно не работает: 

        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);
    }

1 Ответ

0 голосов
/ 25 апреля 2019

Эти настройки не поддерживаются транспортом NServiceBus RabbitMQ.

...