BrokeredMessage entsorgt

Question

Ich habe ein Problem bei der Kennzeichnung meiner BrokeredMessage als Complete.

Einfache Code, der wie funktioniert erwartet:

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

    //do things with myObj 

    message.Complete();    
} 

Wenn ich versuche, für Benutzer zu warten mit myObj zu beenden ich Ausnahme:

brokeredmessage wurde angeordnet

Code unten:

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);   
} 

Für mich sieht es aus wie ServiceBus irgendwie Verbindung zum eigentlichen Objekt in C# Objekt

Etwas ähnliches wie freistehendes Objekt in EF, nur in diesem Fall verlieren wird losgelöst von ServiceBus

EDIT:

Es ist mir wichtig, Nachricht als abgeschlossen nur nach Benutzer klicken Sie auf Schaltfläche. Wenn AC runter geht (oder ähnliche Dinge) Ich möchte Nachrichten bleiben auf Service Bus Thema, so dass das nächste Mal Benutzer starten App wird er wieder Nachrichten erhalten, die er nicht verarbeitet hat.

Answer 1

Sie sollten die brokeredMessage nicht selbst speichern. Wenn Sie das Das Gesamt() -Methode aufrufen, ist es das, was according to the documentation passiert:

schließt die Empfangsoperation einer Nachricht und zeigt an, dass die Nachricht als bearbeitet markiert werden soll und gelöscht

Was sollten Sie stattdessen tun ist zu speichern MyObject Art von Objekten in Ihrem Wörterbuch als vermittelte Nachrichten werden bei Fertigstellung zerstört werden.

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

Und in dem betreffenden Stück Code:

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

Answer 2

einen Blick auf ServiceBus LockToken nehmen.

können Sie komplette nennen (lockToken)

Answer 3

Dies ist sehr implizite und nicht auch weit in der Dokumentation angegeben, wie ich weiß, aber wenn Sie zu einem SB Topic/Abonnement abonnieren, können Sie nur das BrokeredMessage Objekt zugreifen Innerhalb des Ausführungsumfangs des OnMessage Callback-Delegaten, den Sie an SubscriptionClient.OnMessage liefern.

Sobald der Callback zurückkehrt, ist der BrokeredMessage entsorgt.

Wenn Sie die Nachricht zwischenspeichern möchten, und markieren Sie ihn als komplette/aufgegeben/deadletter, sollten Sie die BrokeredMessage.LockToken zwischenzuspeichern, zusammen mit allen anderen Eigenschaft, die Sie wie dem Nachrichtentext benötigen, und verwenden Sie die

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

die eineerhaltenals Parameter, wenn Sie sie als vollständig markieren möchten.