diff --git a/src/MassTransit.RabbitMqTransport/Configuration/Configurators/RabbitMqBusFactoryConfigurator.cs b/src/MassTransit.RabbitMqTransport/Configuration/Configurators/RabbitMqBusFactoryConfigurator.cs index f5b0597bce..6b00b82493 100644 --- a/src/MassTransit.RabbitMqTransport/Configuration/Configurators/RabbitMqBusFactoryConfigurator.cs +++ b/src/MassTransit.RabbitMqTransport/Configuration/Configurators/RabbitMqBusFactoryConfigurator.cs @@ -40,7 +40,8 @@ public RabbitMqBusFactoryConfigurator(IRabbitMqEndpointConfiguration configurati _hosts = new BusHostCollection(); - _settings = new RabbitMqReceiveSettings("ignore", "fanout", false, true); + var queueName = _configuration.ConsumeTopology.CreateTemporaryQueueName("bus-"); + _settings = new RabbitMqReceiveSettings(queueName, "fanout", false, true); _settings.SetQueueArgument("x-expires", TimeSpan.FromMinutes(1)); _settings.SetExchangeArgument("x-expires", TimeSpan.FromMinutes(1)); } @@ -135,9 +136,6 @@ public IRabbitMqHost Host(RabbitMqHostSettings settings) var host = new RabbitMqHost(settings); _hosts.Add(host); - if (_hosts.Count == 1 && string.IsNullOrWhiteSpace(_settings.QueueName)) - _settings.QueueName = _configuration.ConsumeTopology.CreateTemporaryQueueName("bus-"); - return host; }