creatQueue question

[ZhaoYouBo]

The local server 127.0.0.1 already has a queue, but when I use creatQueue, it doesn't detect it and continues to create a new one.

[WollZebra]

Greetings, I do not know what happened before. I use it like this:

constructor: { ... m_RabbitMQ.setHost(m_Host); m_RabbitMQ.setUsername(m_User); m_RabbitMQ.setPassword(m_Pass); m_RabbitMQ.setAutoReconnect(true); ... }

` void bindToChanges(const QString &exchangeName ) { // exchangeName == "something.state"; createExchange(exchangeName, name); auto *queue = createQueue(l, exchangeName, name); bindQueueToExchange(queue, exchangeName, name); }

void createExchange(const RabbitMQContext &exchangeName, const FeatureName &name) { auto exc = m_RabbitMQ.createExchange(exchangeName); connect(exc, &QAmqpExchange::declared, exc, [exchangeName, exc, name] { qDebug() << "RabbitMQ [] Declared Exchange" << name << exchangeName << exc->isDeclared(); }); exc->declare(QAmqpExchange::FanOut, QAmqpExchange::Durable); }

QAmqpQueue createQueue(Bindable l, const RabbitMQContext &exchangeName, const FeatureName &name) { auto queue = m_RabbitMQ.createQueue(name + m_QueueSuffix.value()); emit queueCreated(queue); const auto rerequest = m_Feats.value(name).rabbitMqSendsSingleItemUpdates; disconnect(queue, 0, 0, 0); // in case this is a reconnect connect(queue, &QAmqpQueue::declared, this, [=] { connect(queue, &QAmqpQueue::messageReceived, this, [=] { auto data = queue->dequeue().payload(); qDebug() << "RabbitMQ update" << l->m_FeatureName << data.first(qMin(200, data.length())) << "..."; if (rerequest) { reRequestRestValue(name); return; } l->value = data; }); queue->consume(QAmqpQueue::coNoAck); qDebug() << "RabbitMQ [] Declared Queue" << l->m_FeatureName << queue->name(); }); queue->declare(); return queue; }

void bindQueueToExchange(QAmqpQueue queue, const RabbitMQContext &exchangeName, const FeatureName &name) { connect(queue, &QAmqpQueue::bound, this, [name, exchangeName, queue] { qDebug() << "RabbitMQ [] Bound Queue" << name << queue->name() << "to exchange " << exchangeName << " waiting for updates"; }); queue->bind(exchangeName, ""); } `