RabbitMQのEventBasicConsumer

Question

背景INFO

働いていない私は、RabbitMQの中（電子メール用）のキューを持って、そしてそれのために消費者を構築したいです。このキューは、顧客に電子メールを送信するために別の.NETアプリケーションによって使用されます。電子メールロジックを.NETアプリケーションの外に置いて、耐久性... RabbitMQが提供するメリットがあることを望みました。

ISSUE

.NETアプリがキューにプッシュ型電子メール/公開することができますが、私は難しさ、消費者の構築を持っています！ここでは、消費者のための私のコードです：

// 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); 
    } 
    } 
} 

上記のコードは、キューからメッセージを取得し、（このofficial guideに応じて）それらを処理することができるはずですが、これは起きていません。

Answer 1

問題は時期尚早の接続処理です。人々はしばしばBasicConsumeがブロッキングコールだと思っていますが、そうではありません。それはほとんど直ちに戻り、次の声明はチャンネルと接続の廃止（閉鎖）であり、もちろんあなたのサブスクリプションをキャンセルします。したがって、接続とモデルをプライベートフィールドに格納して、キュー消費が完了したときにだけ破棄してください。

Answer 2

あなたはキューが別の.Netアプリケーションで使用されていると言っていますが、別の消費者ですか？それが別の消費者であれば、どの交換機を使用しているか確認してください。複数の消費者がメッセージを受け取るようにするには、「FanOut」エクスチェンジで先に進んでください。