diff --git a/Connectors/src/RabbitMQ/Controllers/HomeController.cs b/Connectors/src/RabbitMQ/Controllers/HomeController.cs
index 0fb772c32..3947c504e 100644
--- a/Connectors/src/RabbitMQ/Controllers/HomeController.cs
+++ b/Connectors/src/RabbitMQ/Controllers/HomeController.cs
@@ -83,7 +83,7 @@ public async Task<IActionResult> Receive(CancellationToken cancellationToken)
     private static async Task CreateQueueAsync(IChannel channel, CancellationToken cancellationToken)
     {
         await channel.ExchangeDeclareAsync(RabbitExchangeName, ExchangeType.Direct, cancellationToken: cancellationToken);
-        await channel.QueueDeclareAsync(RabbitQueueName, false, false, false, cancellationToken: cancellationToken);
+        await channel.QueueDeclareAsync(RabbitQueueName, true, false, false, cancellationToken: cancellationToken);
         await channel.QueueBindAsync(RabbitQueueName, RabbitExchangeName, RabbitRoutingKey, cancellationToken: cancellationToken);
     }