如何在ServiceBus上通过sequenceNumber使用MessageReceiver.Receive方法

2023-11-27

我正在尝试从死信队列重新提交消息。

我可以重播死信队列上的消息,这很好。 问题是当我现在想从死信队列中删除它时。

这是我正在尝试做的事情:

var subscription = "mySubscription";
var topic = "myTopic";

var connectionString = "connectionStringOnAzure";
var messagingFactory = MessagingFactory.CreateFromConnectionString(connectionString);

var messageReceiver = messagingFactory.CreateMessageReceiver(SubscriptionClient.FormatDeadLetterPath(topic, subscription), ReceiveMode.ReceiveAndDelete);


long messageSequenceNumber = 835;
var brokeredMessage = messageReceiver.Receive(messageSequenceNumber);  // this part fails

// mark message as complete to remove from the queue
brokeredMessage.Complete();

我收到以下错误消息:

 Microsoft.ServiceBus.Messaging.MessageNotFoundException : Failed to lock one or more specified messages. The message does not exist..TrackingId:ae15edcc-06ac-4d2b-9059-009599cf5c4e_G5_B15,TimeStamp:8/13/2013 1:45:42 PM

但是,我没有指定消息序列号,而是使用 ReceiveBatch(如下所示),这样就可以了。

// this works and does not throw any errors
var brokeredMessages = messageReceiver.ReceiveBatch(10);

我错过了什么吗?或者是否有另一种方法来重新处理死信并将其删除?


死信队列像任何其他队列一样按顺序处理。

Receive(seqNo) 方法与 Defer() 结合使用,后者将消息放入不同的辅助队列 - “延迟队列”。延迟队列适用于以下情况:您获取的消息不符合预期顺序(例如,在状态机中),并且需要一个地方来放置提前到达的消息。您可以使用 Defer() 停放这些消息并记下该消息(甚至可能在会话状态下),然后在准备好后提取消息。例如,SharePoint 使用的 Workflow Manager 运行时就使用该功能。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何在ServiceBus上通过sequenceNumber使用MessageReceiver.Receive方法 的相关文章

随机推荐