RabbitMQ EventBasicConsumer ne fonctionne pas

Question

CONTEXTE INFO

J'ai une file d'attente (des e-mails) à RabbitMQ, et que vous voulez construire un consommateur pour lui. La file d'attente est utilisée par une autre application .NET pour l'envoi de courriels aux clients. Je voulais que la logique de l'emailing soit installée en dehors de l'application .NET, et qu'elle ait aussi les avantages de la durabilité ... etc qu'offre RabbitMQ.

NUMÉRO

L'application .NET est en mesure de publier/push e-mails sur la file d'attente, mais je du mal à élaborer le consommateur! Voici mon code pour le consommateur:

// A console app that would be turned into a service via TopShelf 
public void Start() 
{ 
    using (_connection = _connectionFactory.CreateConnection()) 
    { 
    using (var model = _connection.CreateModel()) 
    { 
     model.QueueDeclare(_queueName, true, false, false, null); 
     model.BasicQos(0, 1, false); 

     var consumer = new EventingBasicConsumer(model); 
     consumer.Received += (channelModel, ea) => 
     { 
     var message = (Email) ea.Body.DeSerialize(typeof(Email)); 
     Console.WriteLine("----- Email Processed {0} : {1}", message.To, message.Subject); 
     model.BasicAck(ea.DeliveryTag, false); 
     }; 
     var consumerTag = model.BasicConsume(_queueName, false, consumer); 
    } 
    } 
} 

Le code ci-dessus doit être en mesure de saisir les messages de la file d'attente et de les traiter (selon ce official guide), mais cela ne se produit pas.

Answer 1

Le problème est l'élimination prématurée des connexions. Les gens pensent souvent que BasicConsume est un appel bloquant, mais ce n'est pas le cas. Il reviendra presque immédiatement, et la déclaration suivante mettra fin à la chaîne et à la connexion, ce qui bien sûr annulera votre abonnement. Donc, pour réparer - stocker la connexion et le modèle dans des champs privés et ne les disposer que lorsque vous avez terminé avec la consommation de la file d'attente.

Answer 2

Vous avez dit que la file d'attente est utilisée par une autre application .Net, est-ce un autre consommateur? Si c'est un autre consommateur, pouvez-vous s'il vous plaît confirmer l'échange que vous utilisez? Si vous voulez que plusieurs consommateurs prennent le message, passez à l'échange "FanOut"