Абонент Пахо on_message/on_connect не работает ⇐ Python

[Anonymous]

Я установил Mosquitto и без проблем использовал его в терминале, также установил paho для c++, и mosquitto, и paho работают хорошо.
Затем установил paho для Python через pip. Теперь я пытаюсь протестировать это с помощью этого кода, но функции on_message и on_connect никогда не вызываются. Я делаю

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

mosquitto_pub -h localhost -t "test" -m "This is a message"

пока скрипт Python работает, но не работает. Он никогда не доходит до строки, в которой печатается «on_message!»

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

import paho.mqtt.client as mqtt

def on_connect(self, mqtt_client, obj, flags, rc):
mqtt_client.subscribe("test")

def on_message(self, mqtt_client, obj, msg):
print "on_message()"

print "Initializing subscriber"
mqtt_client = mqtt.Client()
mqtt_client.on_connect = on_connect
mqtt_client.on_message = on_message
mqtt_client.connect("localhost",1883)
print "Listening"
while True:
mqtt_client.loop()

Что я делаю не так?

Подробнее здесь: https://stackoverflow.com/questions/379 ... ot-working