Azure Webjobs ServiceBusTrigger - effectue une fonction différente lorsque MaxDeliveryCount est atteint

Question

J'ai plusieurs WebJobs avec des déclencheurs ServiceBus, et j'ai un MessageProcessor personnalisé pour faire un traitement après le traitement du message. Je voudrais pouvoir faire quelque chose de différent (en particulier, consigner une erreur au lieu d'un avertissement) si le message est sur sa dernière tentative, c'est-à-dire qu'il est sur le point d'être envoyé à la file d'attente. Le BrokeredMessage envoyé dans la fonction CompleteProcessingMessageAsync a le DeliveryCount, mais je ne vois pas un moyen de revenir à la file d'attente d'origine pour trouver le MaxDeliveryCount. Des idées? Les différentes files d'attente ont des MaxDeliveryCounts différents, donc la définition d'une constante n'est pas vraiment une option. La seule autre chose que je peux penser est de créer un travail séparé pour la file d'attente de lettres mortes de chaque file, mais j'aimerais pouvoir le faire au niveau de WebJob plutôt que pour chaque travail individuel.

public class CustomMessageProcessor : MessageProcessor 
{ 
    public CustomMessageProcessor(OnMessageOptions messageOptions) : base(messageOptions) 
    { 
    } 

    public override async Task CompleteProcessingMessageAsync(BrokeredMessage message, FunctionResult result, CancellationToken cancellationToken) 
    { 
     if (result.Succeeded) 
     { 
      if (!MessageOptions.AutoComplete) 
      { 
       cancellationToken.ThrowIfCancellationRequested(); 
       await message.CompleteAsync(); 
      } 
     } 
     else 
     { 
      cancellationToken.ThrowIfCancellationRequested(); 

      //some other processing 

      //If message.DeliveryCount < maxDeliveryCount 
      // log warning 
      //else 
      // log error 

      await message.AbandonAsync(); 
     } 
    } 
} 

Answer 1

Vous devriez être en mesure d'obtenir Microsoft.ServiceBus.Messaging.QueueDescription de la file d'attente des parents, puis utilisez MaxDeliveryCount dehors. La seule chose est qu'obtenir la description de la file d'attente est une opération relativement coûteuse, donc je vous recommande de le faire une fois initialement, et mettre en cache la valeur pour chaque file d'attente.

Answer 2

différentes files d'attente ont des MaxDeliveryCounts, donc définir une constante n'est pas vraiment une option

Comme Slava Asipenko mentionné que nous pourrions mettre MaxDeliveryCount pour la file d'attente servicebus.

comment puis-je travaille quelle file d'attente le message est venu de

On peut obtenir les propriétés du message pour connaître le nom de la file d'attente si représenterons-nous lors de l'envoi. Prenez Label par exemple:

var message = new BrokeredMessage(object); 
message.Label = "queue name"; 
client.Send(message);