Skip to content

Commit

Permalink
Comment
Browse files Browse the repository at this point in the history
  • Loading branch information
danielmarbach committed Sep 20, 2024
1 parent f012ae7 commit 7bde1bd
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 7bde1bd

Please sign in to comment.