Verwenden von ExceptionReceived in OnMessageOptions

Question

Ich versuche, die Methode QueueClient.OnMessage(Action<BrokeredMessage>, OnMessageOptions) zu verwenden. Im OnMessageOptions codierte ich diese einfache ExceptionReceived Veranstaltung:

void LogErrors(object sender, ExceptionReceivedEventArgs e) 
{ 
    if (e.Exception != null) 
    { 
    Trace.TraceError("Exception captured: " + e.Exception.Message); 
    } 
} 

Mein Zweifel ist, wie den „LogErrors“ die BrokeredMessage zu erhalten, die processend in dem Rückruf, um ein Protokoll mit Fehlern zu sparen, wenn BrokeredMessages aufgetreten ist sein werden.

Answer 1

Ich versuchte zu sehen, wie die Nachricht von/innerhalb der ExceptionReceived Rückruf erhalten, aber die Informationen sind nicht in den Argumenten vorhanden. Hier ist mein Beispielcode:

var connectionString = "my-connection-string"; 
var queueName = "my-queue-name"; 
var client = QueueClient.CreateFromConnectionString(connectionString, queueName); 

var options = new OnMessageOptions(); 
options.ExceptionReceived += (sender, args) => 
{ 
    // Neither sender or args contains information about the message being processed 
}; 

client.OnMessage(brokeredMessage => 
{ 
    throw new Exception(); 
}, options); 

Je nach Bedarf, die einfache Lösung ist der Rückruf in einem try/catch wickeln:

client.OnMessage(brokeredMessage => 
{ 
    try 
    { 
     // Process the message 
     ... 

     // Complete the message (depends on the) 
     brokeredMessage.Complete(); 
    } 
    catch (Exception ex) 
    { 

     Trace.TraceError("Exception captured: " + ex.Message); 

     // Here you have access to the brokeredMessage so you can log what you want. 
     ...  
     //Abandon the message so that it could be re-process ?? 
     brokeredMessage.Abandon();   
    } 

}, options); 

Nachdem Sie diese Wrapper in Funktion setzen können, oder erstellen eine Erweiterungsmethode für QueueClient:

public static class QueueClientExtensions 
{ 
    public static void OnCustomMessage(this QueueClient queueClient, Action<BrokeredMessage> callback, 
     OnMessageOptions onMessageOptions) 
    { 
     queueClient.OnMessage(message => 
     { 
      try 
      { 
       // process the message 
       callback(message); 

       //complete if success 
       message.Complete(); 
      } 
      catch (Exception ex) 
      { 
       // Here you have access to the brokeredMessage so you can log what you want. 
       // message.GetBody<string>() 
       Trace.TraceError("Exception captured: " + ex.Message); 

       //Abandon the message so that it could be re-process 
       message.Abandon(); 
      } 

     }, onMessageOptions); 
    } 
} 

Und rufen Sie diese Methode auf die gleiche Weise:

var queueClient = QueueClient.CreateFromConnectionString(connectionString, queueName); 
queueClient.OnCustomMessage(brokeredMessage => 
{ 
    // Process the message 
    ... 
}, new OnMessageOptions());