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(/* ... */);