From 7bde1bdb702e6eb5dcf488b486fbb7dfb8519d17 Mon Sep 17 00:00:00 2001 From: danielmarbach Date: Fri, 20 Sep 2024 17:43:25 +0200 Subject: [PATCH] Comment --- .../Connection/ConfirmsAwareChannel.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/NServiceBus.Transport.RabbitMQ/Connection/ConfirmsAwareChannel.cs b/src/NServiceBus.Transport.RabbitMQ/Connection/ConfirmsAwareChannel.cs index 4c369c7c8..354886d82 100644 --- a/src/NServiceBus.Transport.RabbitMQ/Connection/ConfirmsAwareChannel.cs +++ b/src/NServiceBus.Transport.RabbitMQ/Connection/ConfirmsAwareChannel.cs @@ -39,7 +39,7 @@ public async Task SendMessage(string address, OutgoingMessage message, BasicProp var routingKey = DelayInfrastructure.CalculateRoutingKey((int)delayValue, address, out var startingDelayLevel); await routingTopology.BindToDelayInfrastructure(channel, address, DelayInfrastructure.DeliveryExchange, DelayInfrastructure.BindingKey(address), cancellationToken).ConfigureAwait(false); - // TODO: Seems to be off that we use here the channel directly instead of the routingTopology + // The channel is used here directly because it is not the routing topologies concern to know about the sends to the delay infrastructure await channel.BasicPublishAsync(DelayInfrastructure.LevelName(startingDelayLevel), routingKey, true, properties, message.Body, cancellationToken).ConfigureAwait(false); } else