如何解决创建队列时rsmq队列已经存在的错误?

j2cgzkjk  于 2021-06-09  发布在  Redis
关注(0)|答案(0)|浏览(419)

我正在使用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")
            }
        });    
    }
});

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题