CODEWITHSUNDEEP
pythonubuntumqttmosquittopaho
Martin Ventura
Martin Ventura

Reputation: 197

Paho(MQTT) client can't connect

I'm using this python script to implement a basic Paho(MQTT) subscriber but under certain circumstances it doesn't invoke on_connect.

I tried the following, all with exactly the same code:

I also usually do:

Also tried all setup methods listed in the official website. So python's paho library doesn't seem to be getting along with my local broker unless I run it from my raspberry. But using the same broker works well with c++'s paho library and if using MQTT from the terminal. Any ideas of what can be happening?

     import paho.mqtt.client as mqtt

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

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

     mqtt_client = mqtt.Client()
     mqtt_client.on_connect = on_connect
     mqtt_client.on_message = on_message
     mqtt_client.connect("127.0.0.1",1883)
     mqtt_client.loop_forever()

Upvotes: 5

Views: 13360

Answers (1)

debihiga
debihiga

Reputation: 246

I had the same problem and changing the version of MQTT protocol in Client's constructor solved it.

mqtt_client = mqtt.Client("", True, None, mqtt.MQTTv31)

Since you do not specify the protocol, it uses the default one: MQTTv311.

Upvotes: 14

Related Questions