Ist die Verwendung von QueueClient.OnMessage innerhalb einer asynchronen Methode sinnvoll?

Question

Ich rufe eine asynchrone Methode InsertOperation von einer asynchronen Methode ConfigureConnectionString. Benutzt ich den client.OnMessage-Aufruf richtig? Ich möchte die Nachrichten in einer Warteschlange asynchron verarbeiten und sie dann im Warteschlangenspeicher speichern.

private static async void ConfigureConnectionString() 
    { 
     var connectionString = 
      "myconnstring"; 
     var queueName = "myqueue"; 

     CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("StorageConnectionString")); 
     CloudTableClient tableClient = storageAccount.CreateCloudTableClient(); 

     CloudTable table = tableClient.GetTableReference("test"); 
     table.CreateIfNotExists(); 
     Stopwatch sw = Stopwatch.StartNew(); 
     await Task.Run(() => InsertOperation(connectionString, queueName, table)); 
     sw.Stop(); 
     Console.WriteLine("ElapsedTime " + sw.Elapsed.TotalMinutes + " minutes."); 

    } 


private static async Task InsertOperation(string connectionString, string queueName, CloudTable table) 
    { 

     var client = QueueClient.CreateFromConnectionString(connectionString, queueName); 
     client.OnMessage(message => 
     { 

      var bodyJson = new StreamReader(message.GetBody<Stream>(), Encoding.UTF8).ReadToEnd(); 
      var myMessage = JsonConvert.DeserializeObject<VerifyVariable>(bodyJson); 

      Console.WriteLine(); 

      var VerifyVariableEntityObject = new VerifyVariableEntity() 
      { 
       ConsumerId = myMessage.ConsumerId, 
       Score = myMessage.Score, 
       PartitionKey = myMessage.ConsumerId, 
       RowKey = myMessage.Score 
      }; 
     }); 
    } 

Answer 1

OnMessageAsync method bietet Asynchron-Programmiermodell, das uns ermöglicht, asynchron eine Nachricht zu verarbeiten.

client.OnMessageAsync(message => 
{ 
    return Task.Factory.StartNew(() => ProcessMessage(message)); 
    //you could perofrm table and queue storage in ProcessMessage method 
}, options); 

Answer 2

Ohne die tatsächliche Logik zu verstehen, die Sie erreichen möchten, sieht es so aus, als ob Sie OnMessage nicht korrekt verwenden.

OnMessage ist eine Möglichkeit, das Warteschlangenclientverhalten für einen Client mit langer Laufzeit einzurichten. Dies ist beispielsweise sinnvoll, wenn Sie in Ihrer Anwendung eine Singleton-Instanz haben. In diesem Fall geben Sie dem Client an, wie Sie mit allen Nachrichten umgehen möchten, die in die Warteschlange eingereiht werden.

In Ihrem Beispiel erstellen Sie jedoch den Client, richten die OnMessage ein und behalten den Client nicht bei, so dass effektiv nichts erreicht wird.