node.js - 在 node-amqp (node.js) 中处理独占队列订阅时出错

Question

当您订阅独占队列(一次只允许一个消费者)时，当队列超额订阅(已经有消费者)时，node-amqp 会抛出异常。

• 我尝试过使用 .on("error",cb) 语法。
• 我尝试过错误域( Node 0.10.0)
• 尝试/捕获显然不起作用

这是我的订阅行，但没什么特别的:

queue.subscribe({ack: true, prefetchCount: 1, exclusive: exclusive}, cbExecute).addCallback((ok) -> listeners[type] = ok.consumerTag);

使用队列时抛出未处理的异常:

ACCESS_REFUSED - queue 'respQ' in vhost 'brkoacph' in exclusive use

查看node-amqp内部，我发现它们在模块内部实现了一个独立的任务队列，以便当错误发生时，任务在独立的上下文中运行。

有任何解决方法/修复吗？ ...或者我只是做错了什么？

Answer 1

我认为您想要做的是捕获AMQP连接中的错误。正如您所提到的，node-amqp 捕获不同上下文中的错误，但您可以在连接上监听:

yourConnectionVar.on( 'error', function(err) {
  //do something
  console.log('An error occurred' + err);
});

我希望这会有所帮助。

干杯!