2014-05-06 43 views
0

我有一個頻道沒有在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儀表板中。

回答

0

的AMQP的咖啡的最新版本目前支持以下功能:

consumer.close();

爲我一個人困惑的一點是從哪裏得到的消費對象。它從connection.consume調用返回:

var consumer = connection.consume(/* ... */);