从死信队列重新提交邮件-Azure服务总线

Question

我在Azure中创建了一个服务总线队列，它运行良好。如果消息没有在默认尝试（10次）内传递，则将消息正确地移动到死信队列。

现在，我想从死信队列中重新提交这条消息，回到它起源的队列，看看它是否再次工作。我也尝试过使用服务总线浏览器。但它立即被转移到死信队列中。

是否有可能这样做，如果有，如何做？

Answer 1

尝试删除死信原因

resubmittableMessage.Properties.Remove("DeadLetterReason");
resubmittableMessage.Properties.Remove("DeadLetterErrorDescription");

完整代码

using Microsoft.ServiceBus.Messaging;
using System.Transactions;

namespace ResubmitDeadQueue
{
    class Program
    {
        static void Main(string[] args)
        {

            var connectionString = "";
            var queueName = "";

            var queue = QueueClient.CreateFromConnectionString(connectionString, QueueClient.FormatDeadLetterPath(queueName), ReceiveMode.PeekLock);

            BrokeredMessage originalMessage
                ;
            var client = QueueClient.CreateFromConnectionString(connectionString, queueName);
            do
            {
                originalMessage = queue.Receive();
                if (originalMessage != null)
                {
                    using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
                    {
                        // Create new message
                        var resubmittableMessage = originalMessage.Clone();

                        // Remove dead letter reason and description
                        resubmittableMessage.Properties.Remove("DeadLetterReason");
                        resubmittableMessage.Properties.Remove("DeadLetterErrorDescription");

                        // Resend cloned DLQ message and complete original DLQ message
                        client.Send(resubmittableMessage);
                        originalMessage.Complete();

                        // Complete transaction
                        scope.Complete();
                    }
                }
            } while (originalMessage != null);
        }
    }
}

感谢这里的一些其他回复！

Answer 2

这可能是Peter Berggreen指出的“重复消息检测”，或者更可能是，如果您直接将代理消息从死信队列移动到实时队列，那么DeliveryCount仍将处于最大值，并且它将返回死信队列。

从死信队列中提取BrokeredMessage，使用GetBody（）获取内容，使用该数据在新的BrokeredMessage中创建并将其发送到队列。您可以在一个安全的庄园中这样做，通过使用peek从死信队列中获取消息内容，然后在从死信队列中删除消息之前将新消息发送到活动队列。这样，如果由于某种原因未能写入活动队列，您就不会丢失任何关键数据。

使用新的BrokeredMessage，您不应该有“重复消息检测”的问题，并且DeliveryCount将被重置为零。

Answer 3

您需要发送具有相同负载的新消息。ASB按设计不支持邮件重新提交。