c# - 如何使用 .net core c# 将消息从 Deadletter 主题发送到 Main 并完成它

Question

我可以使用下面的代码从 Deadletter 向 Main 发送消息，但问题无法完成该消息。

这一行出错 -等待 deadletterReceiver.CompleteAsync(newMessage.SystemProperties.LockToken);

System.InvalidOperationException: Operation is not valid due to the current state of the object. at Microsoft.Azure.ServiceBus.Message.SystemPropertiesCollection.ThrowIfNotReceived() at Microsoft.Azure.ServiceBus.Message.SystemPropertiesCollection.get_LockToken()

public static async System.Threading.Tasks.Task RunAsync([TimerTrigger("0 */2 * * * *")]TimerInfo myTimer, ILogger log)
{
    log.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");
    try
    {

        var deadQueuePath = EntityNameHelper.FormatDeadLetterPath("demo/subscriptions/demo");

        MessageReceiver deadletterReceiver = new MessageReceiver(Environment.GetEnvironmentVariable("ConnectionStringSettingName"), deadQueuePath, ReceiveMode.PeekLock,RetryPolicy.Default);
        MessageSender sender = new MessageSender(Environment.GetEnvironmentVariable("ConnectionStringSettingName"), "demo",RetryPolicy.Default);

        var deadLetter = await deadletterReceiver.ReceiveAsync();
        if (deadLetter != null)
        {
            log.LogInformation($"got new message");

            Message newMessage = new Message(deadLetter.Body)
            {
                ContentType = deadLetter.ContentType,
                CorrelationId = deadLetter.CorrelationId                          
            };

            //Send the message to the Active Queue
            await sender.SendAsync(newMessage);
            await deadletterReceiver.CompleteAsync(newMessage.SystemProperties.LockToken); //Unlock the message and remove it from the DLQ
            log.LogInformation($"Unlock the message and remove it from the DLQ");
        }
    }
    catch (Exception ex)
    {
        log.LogInformation($"Exception: {ex}");
    }
}

Answer 1

您不应该使用死信消息中的锁定 token 吗？

本质上改变这行代码:

 await deadletterReceiver.CompleteAsync(newMessage.SystemProperties.LockToken); //Unlock the message and remove it from the DLQ

至

 await deadletterReceiver.CompleteAsync(deadLetter.SystemProperties.LockToken); //Unlock the message and remove it from the DLQ