微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

c# – Mark Azure Queue BrokeredMessage已成功处理?

我以worker角色接收队列消息,但是当我尝试将brokeredMessage标记为完成时.我得到以下错误

Client.OnMessage((receivedMessage) =>
    {
        try
        {
            FileContainer fileInfoObj = receivedMessage.GetBody<FileContainer>();               
            //Message processing code               

            receivedMessage.Complete();                           

        }
        catch
        {
            receivedMessage.DeadLetter();
        }
    });

The lock supplied is invalid. Either the lock expired, or the message
has already been removed from the queue.

我错过了什么吗?

解决方法:

根据Mike Z的评论,在创建队列以防止超时时设置LockDuration(认值为1,最长可达5分钟).

QueueDescription qd = new QueueDescription("MyQueue");
qd.LockDuration = ...

if (!namespaceManager.QueueExists("MyQueue"))
{
    namespaceManager.CreateQueue(qd);
}

另外,使用RenewLock防止它在长时间过程中超时:

receivedMessage.RenewLock()

从这里:
https://stackoverflow.com/a/15305150/188926

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐