Очередь RabbitMQ получила сообщение, которое не принадлежит очереди ⇐ C++

[Anonymous]

Привет, я хочу спросить. Я пробовал много раз и много решений, но все еще имею эту проблему: мой клиент отправляет одно сообщение в очередь A, но моя очередь B получит сообщение. Иногда очередь A может получить сообщение, а иногда нет.

• Правильна ли моя реализация?
• когда обе очереди стоят в очереди связаны в одном обмене, при отправке сообщения с ключом маршрутизации будет получена только указанная очередь?
• как работает amqp_consume_message?

...

Код: Выделить всё

//Consumer function for Queue A
void consumeQueueA(amqp_connection_state_t conn) {
//amqp_channel_open(conn, 1);
binding_mutex.lock();

amqp_queue_declare_ok_t* res = amqp_queue_declare(conn, 1, amqp_cstring_bytes("Queue_A"), 0, 1, 0, 1, amqp_empty_table);

if (!res) {
amqp_rpc_reply_t reply = amqp_get_rpc_reply(conn);
if (reply.reply_type != AMQP_RESPONSE_NORMAL) {
std::cerr 

Подробнее здесь: [url]https://stackoverflow.com/questions/79029922/rabbitmq-queue-received-message-which-not-belongs-to-the-queue[/url]