Paho Teilnehmer on_message/on_connect funktioniert nicht

Question

Ich habe Mosquitto installiert und im Terminal ohne Problem verwendet, auch installiert Paho für C++, sowohl Moskito und Paho gut funktionieren. Dann installiert Paho für Python über Pip. Jetzt versuche ich es mit diesem Code zu testen, aber die Funktionen on_message und on_connect werden nie aufgerufen. Ich mache

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

während der Python-Skript läuft, aber es funktioniert nicht. Es kommt nie zu der Zeile, die "on_message" ausgibt.

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() 

Was mache ich falsch?

Answer 1

Das folgende funktioniert gut für mich.

Ich habe die self aus den Rückrufen entfernt und tauschte die Schleife für mqtt_client.loop_forever()

import paho.mqtt.client as mqtt 

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

def on_message(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" 
mqtt_client.loop_forever()