Я использую библиотеку node-amqp для своего проекта nodejs. Я также разместил проблему на странице проекта github.
Он продолжает создавать новые каналы, и они остаются бездействующими навсегда. Через час каналов было ~12000. Я проверил варианты обмена и публикации, но пока я даже не близок к решению.
Что не так с кодом и/или есть ли какие-либо параметры/настройки для сервера rabbitmq для этой проблемы?
Вот пример кода:
connection.exchange("brcks-wfa",{type:'direct',durable:true}, function(exchange) {
setInterval(function() {
...
awS.forEach(function(wc){
...
nstbs.forEach(function(br){
...
BUpdate(brnewinfo,function(st){
if(st){
exchange.publish(route, brnewinfo,{contentType:"application/json"});
}
});
});
...
});
}, 4000);
});