diff --git a/src/NebulaBus/Rabbitmq/RabbitmqProcessor.cs b/src/NebulaBus/Rabbitmq/RabbitmqProcessor.cs
index 64943e55a9f570a1759f725c8662c9e758924422..5b932dba977a180190c0ca8ab840551761331ffc 100644
--- a/src/NebulaBus/Rabbitmq/RabbitmqProcessor.cs
+++ b/src/NebulaBus/Rabbitmq/RabbitmqProcessor.cs
@@ -75,7 +75,7 @@ namespace NebulaBus.Rabbitmq
                         await channel.BasicQosAsync(0, qos.Value, false);
 
                     //Create Exchange
-                    await channel.ExchangeDeclareAsync(_rabbitmqOptions.ExchangeName, ExchangeType.Direct);
+                    await channel.ExchangeDeclareAsync(_rabbitmqOptions.ExchangeName, ExchangeType.Direct, true);
                     //Create Queue
                     await channel.QueueDeclareAsync(handler.Name, true, false, false, null);