Skip to content

Commit 59f9044

Browse files
committed
Rabbit MQ queues will not appropriately use the correct DLQ mechanism for the various configuration options.
1 parent db4c69c commit 59f9044

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

src/Transports/RabbitMQ/Wolverine.RabbitMQ/Internal/RabbitMqQueue.cs

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -368,8 +368,14 @@ public override async ValueTask<IListener> BuildListenerAsync(IWolverineRuntime
368368

369369
public override bool TryBuildDeadLetterSender(IWolverineRuntime runtime, out ISender? deadLetterSender)
370370
{
371-
var dlq = _parent.Queues[DeadLetterQueue?.QueueName ?? _parent.DeadLetterQueue.QueueName];
372-
deadLetterSender = dlq.CreateSender(runtime);
373-
return true;
371+
if (DeadLetterQueue is { Mode: DeadLetterQueueMode.Native })
372+
{
373+
var dlq = _parent.Queues[DeadLetterQueue?.QueueName ?? _parent.DeadLetterQueue.QueueName];
374+
deadLetterSender = dlq.CreateSender(runtime);
375+
return true;
376+
}
377+
378+
deadLetterSender = default;
379+
return false;
374380
}
375381
}

0 commit comments

Comments
 (0)