我正在使用rsmq包实现redis pubsub服务。这个 createQueue
函数返回队列已存在,但 listQueues
函数正在显示任何此类队列并返回空数组。代码中也没有从redis中删除队列的函数。
rsmq.listQueues(function (err, queues) {
if (err) {
console.error(err)
return;
}
console.log("Active queues: " + queues.join( "," ) )
console.log(queues); // EMPTY ARRAY
if(!queues.includes(queueName)){
rsmq.createQueue({ qname: queueName }, function (err, resp) {
if (err) {
console.error(err) // throwing error "queue already exists"
return
}
if (resp === 1) {
console.log("queue created")
}
});
}
});
暂无答案!
目前还没有任何答案,快来回答吧!