如何讓IModel.BasicAcks啓動？

Question

我第一次玩RabbitMQ的.NET API，我想出了一個似乎對我來說似乎合理的用例：我想創建發佈者發佈消息並在他們完成Ack-ed後執行某些操作。在IModel.BasicAcks事件似乎是一個體面的方式來了解這一點，so--

我寫了一個出版商：

 private static void Post(string message) { 

      model.ExchangeDeclare("MyExchange", ExchangeType.Fanout, true); 
      model.QueueDeclare("MyQueue", true, false, false, null); 
      model.QueueBind("MyQueue", "MyExchange", "", new Dictionary<string, object>()); 

      byte[] messageBodyBytes = System.Text.UTF8Encoding.ASCII.GetBytes(message); 
      IBasicProperties props = model.CreateBasicProperties(); 
      props.ContentType = "text/plain"; 
      props.DeliveryMode = 2; 
      model.BasicPublish("MyExchange", "", props, messageBodyBytes); 
    } 

和用戶：

private static void Receive() { 
      var gotten = model.BasicGet("MyQueue", false); 
      var text = System.Text.UTF8Encoding.ASCII.GetString(gotten.Body); 
      Console.WriteLine(text); 
      model.BasicAck(gotten.DeliveryTag, false); 
    } 

這是控制檯應用程序的入口點：

 static void Main(string[] args) { 

     connectionFactory = new ConnectionFactory(); 
     connectionFactory.HostName = "localhost"; 
     connection = connectionFactory.CreateConnection(); 
     model = connection.CreateModel(); 
     model.BasicAcks += new RabbitMQ.Client.Events.BasicAckEventHandler(model_BasicAcks); 
     Post("Hello, World!"); 
     Receive(); 
     Console.ReadKey(); 

     connection.Dispose(); 
     model.Dispose(); 

    } 

出於某種原因，我的事件處理程序未被調用。 「你好，世界！」消息被髮布，讀取，Ack和打印到控制檯，但由於某種原因，事件處理程序從不被調用。

我做錯了什麼？訂閱IModel.ModelShutdown似乎工作得很好。

Answer 1

我將這個問題引用到RabbitMQ團隊的答覆中。

Here's what they had to say

簡單的講，該事件觸發，但它不是我想這可能be--這對出版商證實，explained in this RabbitMQ blog post

Answer 2

與API嘗試了很多之後，這裏是什麼工作爲了我。我需要在聲明我的交換和隊列之前聲明我的事件處理程序。

_rabbitMqChannel.BasicAcks += new BasicAckEventHandler(_rabbitMqChannel_BasicAcks); 
_rabbitMqChannel.BasicNacks += new BasicNackEventHandler(_rabbitMqChannel_BasicNacks); 

_rabbitMqChannel.ExchangeDeclare(ExchangeName, ExchangeTypeVal.ToString()); 
_rabbitMqChannel.QueueDeclare(QueueName, QueueDurable, QueueExclusive, QueueDelete, null); 
_rabbitMqChannel.QueueBind(QueueName, ExchangeName, RoutingKey); 

，這裏是事件處理方法將如何看起來像......

private void _rabbitMqChannel_BasicNacks(IModel model, BasicNackEventArgs args) 
{ 
    throw new NotImplementedException(); 
} 

private void _rabbitMqChannel_BasicAcks(IModel model, BasicAckEventArgs args) 
{ 
    throw new NotImplementedException(); 
} 

半天花在這個！希望這有助於某人;）