BrokeredMessage 已处理

Question

我无法将我的 BrokeredMessage 标记为完成。

按预期工作的简单代码：

 private void OnMessageArrived(BrokeredMessage message)
 {
     var myObj= message.GetBody<MyObject>();

     //do things with myObj

     message.Complete();            
 }

当我尝试等待用户完成 myObj 我得到异常：

brokeredmessage 已处理

代码如下：

 private Dictionary<long, BrokeredMessage> ReceivedMessages;      
 ReceivedMessages = new Dictionary<long, BrokeredMessage>();

 private void OnMessageArrived(BrokeredMessage message)
 {
     var myObj= message.GetBody<MyObject>();
     ReceivedMessages.Add(myObj.Id, message);

     //do things with myObj      
 }

 private void Button_Click(object sender, RoutedEventArgs e)
 {
     // get myObj on which user clicked

     ReceivedMessages[myObj.Id].Complete();
     ReceivedMessages.Remove(myObj.Id);        
 }

在我看来，ServiceBus 以某种方式失去了与 c#

中实际对象的连接

类似于 EF 中的分离对象，只是在这种情况下，对象与 ServiceBus

分离

编辑：

只有在用户单击按钮后才将消息标记为完成对我来说很重要。 如果 AC 出现故障（或类似情况），我希望消息仍保留在 Service Bus 主题 上，以便下次用户启动应用程序时，他将再次收到他未处理的消息。

Answer 1

您不应存储代理消息本身。当您调用 .Complete() 方法时，会发生这种情况according to the documentation：

完成一条消息的接收操作，并指示该消息应标记为已处理并删除

您应该做的是在您的字典中存储 MyObject 类型的对象，因为代理消息将在完成后被销毁。

private Dictionary<long, MyObject> ReceivedMessages;      
ReceivedMessages = new Dictionary<long, MyObject>();

在相关的代码中：

 var myObj= message.GetBody<MyObject>();
 ReceivedMessages.Add(myObj.Id, myObj);

Answer 2

据我所知，这是非常隐含的，并且在文档中没有很好地说明，但是当您订阅 SB 主题/订阅时，您只能在 OnMessage 回调的执行范围内访问 BrokeredMessage 对象委托你提供给SubscriptionClient.OnMessage。

一旦回调返回，BrokeredMessage 就会被释放。

如果您想缓存消息并将其标记为完整/已放弃/死信，您应该缓存BrokeredMessage.LockToken，以及您需要的任何其他属性（如消息正文），并使用

• SubscriptionClient.Complete
• SubscriptionClient.Abandon
• SubscriptionClient.Deadletter

当您想将它们标记为完成时，它会接收 LockToken 作为参数。

Answer 3

如果您正在执行异步方法，我发现这也是同样的问题，消息被分派并且在等待发生时，消息已经被释放。我只希望我早点找到这篇文章..

Answer 4

看看 ServiceBus LockToken。

你可以调用 Complete(lockToken)