node.js - node-amqp 队列被破坏 : notifications to subscribers

Question

我正在使用node-amqp和rabbit来实现一些发布/订阅工具。我想知道当某人/某事(在其他进程中)破坏了订阅者正在监听的队列时是否可以通知订阅者。

例如，流程一:

connection.queue(name = "test-queue1", options, function(queue) {

 queue.subscribe({}, function(message, headers, deliveryInfo) {
   deliverMessage(message);
 }).once('error', function(error) {
   logger.error(error)
 }).once("queueDeleteOk", function bindHandler() {
  queue.close();
});

};

现在，其他进程可能会破坏该队列。订户如何知道这一点？例如，流程二可以执行以下操作:

connection.queue(name = "test-queue1", options, function(queue) {
   queue.destroy(delete_options);
}).once("queueDeleteOk", function bindHandler() {
  queue.close();
});

我尝试监听有效的事件“queueDeletedOk”，但它仅在进程二中发出和接收，这会破坏队列。尝试在队列上“关闭”事件也会发生同样的情况。

谢谢并致以最诚挚的问候，

Answer 1

RabbitMQ 支持消费者取消通知:http://www.rabbitmq.com/consumer-cancel.html

我不知道您正在使用的库，但是这里的这个库 [1] 是由前 RabbitMQ 核心开发人员创建的，并且支持消费者取消通知。

1 - http://squaremo.github.io/amqp.node/doc/channel_api.html