chore: remove redundant ExchangeDeclare call

nmshd · Dec 19, 2024 · 3fc84e2 · 3fc84e2
1 parent 567cc4a
commit 3fc84e2
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/BuildingBlocks/src/BuildingBlocks.Infrastructure/EventBus/RabbitMQ/EventBusRabbitMQ.cs b/BuildingBlocks/src/BuildingBlocks.Infrastructure/EventBus/RabbitMQ/EventBusRabbitMQ.cs
@@ -54,8 +54,6 @@ public void Dispose()
 
     public async Task StartConsuming()
     {
-        await _consumerChannel!.ExchangeDeclareAsync(EXCHANGE_NAME, "direct");
-
         if (_consumer is null)
         {
             throw new Exception("Cannot start consuming without a consumer set.");
@@ -162,7 +160,7 @@ private async Task CreateConsumerChannel()
 
         _consumerChannel = await _persistentConnection.CreateChannel();
 
-        await _consumerChannel.ExchangeDeclareAsync(EXCHANGE_NAME, "direct"); // TODO: why declare again? This is already up in StartConsuming
+        await _consumerChannel.ExchangeDeclareAsync(EXCHANGE_NAME, "direct");
 
         await _consumerChannel.QueueDeclareAsync(_queueName,
             durable: true,