如何使用c#将消息从DLQ一一移动到Deffered

Question

我想在特定条件下将消息从 DLQ 移动到延迟，例如如果自定义属性“RetryCount”大于 5，否则我必须将其移动到主队列。将消息从 DLQ 传输到主队列工作正常。但是在从 DLQ 读取到延迟队列后，我没有找到合适的解决方案来移动消息。我正在使用 C# 代码。 注意：我使用的是主题和订阅模型

Answer 1

我们可以使用QueueExplorer 将消息从死信队列中移出。查看此SO 了解更多信息

您还可以根据您的要求使用 Service Bus Explorer 对其进行管理，您可以获取信息here

下面是一个用于转发死信消息的示例代码

var transport = endpointConfiguration.UseTransport<AzureServiceBusTransport>();
var queues = transport.Queues();
queues.ForwardDeadLetteredMessagesTo(
        condition: queueName =>
        {
            return queueName != "error" &&
                   queueName != "audit" &&
                   queueName != "centralizeddlq";
        },
        forwardDeadLetteredMessagesTo: "centralizeddlq");
var subscriptions = transport.Subscriptions();
subscriptions.ForwardDeadLetteredMessagesTo("centralizeddlq");