1
我有一個節點工作者正在等待RabbitMQ消息。今天我對它做了一些改變,現在當我連接開發實例時,一切正常 - 它似乎連接 - 但是然後消耗功能不會觸發。消息仍然消失,儘管他們已經被消耗。RabbitMQ消息神祕消失
Rabbit.queue('consume', function (q) {
q.bind('consume');
// This fires
console.log('Listening to queue...');
q.subscribe(function (message) {
// This doesn't fire but message gets removed from queue
console.log(message);
init(message);
});
});
您確定沒有其他進程正在使用這些消息嗎?你有沒有檢查管理插件,看看發生了什麼? –
它總是在發生嗎?或只是在沉重的負荷下?可能是因爲問題你找到了解決方案嗎?也將有助於知道你使用什麼庫,amqp,amqplib,... – Michael