amqp-咖啡频道没有关闭
问题描述:
我有一个频道没有在amqp-coffee中关闭的问题。当使用节点AMQP我有同样的问题,但与此队列选项解决它:amqp-咖啡频道没有关闭
closeChannelOnUnsubscribe: true
然后当我socket.io客户端断开我会从队列中取消了consumerTag,通道将关闭:
socket.on('disconnect', function() {
if (consumerTag) {
my_queue.unsubscribe(consumerTag);
}
});
amqp-coffee会有等价物吗?我想尝试像queue.channel.close(),consumer.cancel()和queue.delete(),但似乎没有关闭渠道的各种东西。我可以看到它们保持在没有消费者的rabbitmq仪表板中。
答
的AMQP的咖啡的最新版本目前支持以下功能:
consumer.close();
为我一个人困惑的一点是从哪里得到的消费对象。它从connection.consume调用返回:
var consumer = connection.consume(/* ... */);