RabbitMQ - 将消息从经典队列消费到 MQTT 连接

Question

我正在尝试使用 RabbitMQ 中的队列中的消息，该队列已设置并包含一些消息。我正在通过与 paho 库的连接来测试 MQTT 下标：

import paho.mqtt.client as mqtt
from paho.mqtt.enums import CallbackAPIVersion

def on_connect(client, userdata, connect_flags, reason_code, properties):
    print("Connected with result code "+str(reason_code))
    client.subscribe("sv/iqf/area/0/#")

def on_message(client, userdata, msg):
    print("Received message: "+msg.payload.decode())

client = mqtt.Client(callback_api_version=CallbackAPIVersion.VERSION2)  # Provide callback_api_version argument
client.username_pw_set("user", "password")
client.on_connect = on_connect
client.on_message = on_message

client.connect("IP", 1883, 60)

client.loop_forever()

但是，我无法让新的订阅队列（MQTT 连接）使用经典队列消息，如文档中所述：

我当前对经典队列获取消息的设置如下：

MQTT订阅队列设置为：

如果连接已建立并且消息被发送到指定的路由键，那么两个队列都会收到消息，但我的目标是将它们发送到第一个队列，以防订阅者连接不稳定并且可以在连接时使用它们。

我错过了什么？

Answer 1

我正在尝试使用 RabbitMQ 中的队列中的消息，该队列已设置并包含一些消息。

无法通过 MQTT 从 MQTT 插件外部创建的队列进行消费。