0

我一直在使用 EasyNetQ 运行一个简单的 Windows 服务，但是当我尝试发布一条消息时，我收到了一个异常。

例外：

Pubisher confirms timed out after 10 seconds waiting for ACK or NACK from sequence

这是我的发布测试：

try {       
    var queue = _bus.Advanced.QueueDeclare("api-request-history");        
    _bus.Send(queue.Name, message);

} catch (Exception e) {
    Logger.FatalException(string.Format("Message were not queued in queue: {0}", queue.Name), e);                
    OnErrorOccurred(e);     
}

这是我的订阅测试： 

public override void Subscribe(Action<IReceiveRegistration> execution) {
     var queue = _bus.Advanced.QueueDeclare("api-request-history");
     try {
         while (_bus.IsConnected) {
             _bus.Receive(queue.Name, execution);
         }
     } catch (Exception e) {
         Logger.ErrorException("Error occurred", e);
     } finally {
         if (_bus != null) {
             _bus.Dispose();
         }
     }
 }

这是订阅的调用：

_queueConsumer.Subscribe(x => x.Add<ApiRequestHistory>(message => {
    Logger.Info("Initializing subscribtion sequence!");
    Logger.Info("Message data is being saved...");

    Execute();
    Logger.Info("Message data saving is completed!");
    Thread.Sleep(100);
    wait.Set();
}));
wait.Wait();
4

1 回答 1

0

我认为您订阅的方式错误。您不应 _bus.Receive(queueName)为同一个队列多次调用（来自 EasyNETQ 文档）：

注意：您可能不想为同一个队列多次调用 bus.Receive。这将在队列上创建一个新的消费者，RabbitMQ 将在它们之间循环。如果您在不同的 Receive 调用（以及因此不同的消费者）上使用不同的类型，那么您的一些消息将最终出现在错误队列中，因为 EasyNetQ 不会找到与使用它的消费者相关联的消息类型的处理程序。

只需执行一次，您的消费者（每种类型）就会被注册。

这是特别正确的，因为您似乎正在使用publisher confirms。我不太了解您的情况，但通常不需要，除非您有事务性 RPC 调用模型。

检查发布者确认的文档。

于 2014-02-27T15:34:52.527 回答