Langage C#
  1. Langage C#
  3. Nom de la file d’erreurs personnalisée lors de l’utilisation de EasyNetQ pour RabbitMQ?
Intereting Posts
Un exemple de code illustrant la différence entre les paradigmes de l’extension asynchrone / wait et de l’extension Reactive (Rx)? Comment développer une application de bureau à l’aide de C # pouvant utiliser le scanner de codes à barres USB. Comment commencer envoi de plusieurs courriels avec mvcmailer Microsoft SQL Server et SQL Server Management Studio Liaison fortement typée à un DropDownListFor? Installer le service Windows sans InstallUtil.exe comment utiliser un service Web et afficher les données dans mon application Windows Phone Erreur lors de la tentative d’exécution du projet: le module devait contenir un manifeste d’assembly. Comment configurer correctement l’identité du pool d’applications IIS 7? Je ne trouve pas la méthode «Include» avec l’expression lambda dans Entity Framework? Pourquoi un paramètre out ne peut-il pas avoir une valeur par défaut? Obtenir la liste des utilisateurs d’Active Directory dans un groupe AD donné Fournisseur Owin OAuth «Le type d’entité IdentityUser ne fait pas partie du modèle pour le contexte actuel» Comment jouer un fichier son Tous les frameworks d’authentification et d’autorisation pour l’application Windows Form?

Nom de la file d’erreurs personnalisée lors de l’utilisation de EasyNetQ pour RabbitMQ?

Plutôt que de laisser mes exceptions non gérées se retrouver dans EasyNetQ_Default_Error_Queue, je me suis demandé s’il était possible de déclarer explicitement le nom d’une file d’erreurs devant être utilisée pour une application donnée.

Je peux voir comment spécifier des noms de queue de messages normaux, mais je n’ai rien trouvé à propos des noms de queue d’erreur.

Oui, vous pouvez personnaliser les conventions de dénomination en remplaçant les delegates sur l’object IConventions:

https://github.com/EasyNetQ/EasyNetQ/blob/master/Source/EasyNetQ.Tests/ConventionsTests.cs

Cela devrait probablement fonctionner: 

var bus = RabbitHutch.CreateBus("host=localhost"); bus.Advanced.Container.Resolve().ErrorExchangeNamingConvention = info => "MyExchangeNaming"; bus.Advanced.Container.Resolve().ErrorQueueNamingConvention = () => "MyErrorQueueNaming";