RabbitMQ — использовать сообщения из классической очереди для соединения MQTT. ⇐ Python

[Anonymous]

Я пытаюсь получить сообщения из очереди в RabbitMQ, которая уже настроена и содержит несколько сообщений. Я тестирую субскриптор MQTT с подключением к библиотеке paho:

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

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 устанавливается как:


Если соединение установлено и сообщения отправлены на указанный ключ маршрутизации, тогда обе очереди получат сообщения, но моя цель - доставить их в первую очередь в случае, если соединение подписчика нестабильно и может использовать их при каждом подключении.
Что мне не хватает?

Подробнее здесь: https://stackoverflow.com/questions/782 ... connection