创建队列时如何解决rmq队列已存在错误？答案

【问题标题】：how to solve rsmq queue already exits error while creating queue?创建队列时如何解决rmq队列已存在错误？
【发布时间】：2020-12-06 12:30:57
【问题描述】：

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

【问题讨论】：

标签： javascript node.js redis publish-subscribe

【解决方案1】：

rsmq.deleteQueue({ qname: "myqueue" }, function (err, resp) {
    if (err) {
        console.error(err)
        return
    }

    if (resp === 1) {
        console.log("Queue and all messages deleted.")
    } else {
        console.log("Queue not found.")
    }
});

删除队列的代码请参阅 - https://www.npmjs.com/package/rsmq 了解有关 rsmq 的更多信息

【讨论】：