Код ошибки 128 при попытке подписаться на топик в mqtt
В качестве брокера используется hbmqtt 0.9.6, в качестве клиента paho-mqtt 1.5.1. Сам протокол версии 3.1.1.
Конфигурация брокера:
listeners:
default:
type: tcp
halp:
max-connections: 33
bind: 127.0.0.3:1883
topic-check:
enabled: false
auth:
allow-anonymous: true
Код клиента:
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe('abc')
def on_message(client, userdata, msg):
print(msg.topic + " " + str(msg.payload))
def on_subscribe(mosq, obj, mid, qos):
print("Subscribed: " + str(mid))
print("Granted QoS: " + str(qos[0]))
client = mqtt.Client(client_id="subscriber", transport="tcp")
client.on_connect = on_connect
client.on_message = on_message
client.on_subscribe = on_subscribe
client.connect("127.0.0.3", 1883)
client.loop_forever()
Соединение с брокером происходит без проблем, также если добавить публикующего клиента (с примерно таким же кодом), то брокер принимает сообщения и пытается их бродкастить
Что попробовано:
- Изменение имени топика
- Изменение айпи\порта
- Изменение транспорта