Failed to get more than 20 MQTT messages using Mosquitto / Paho for Python
I am using the MQTT client for Muscovite (now Paho) python to connect to the HiveMQ broker. The code is very simple, taken from their documentation here - https://pypi.python.org/pypi/paho-mqtt
#SUBSCRIBER import paho.mqtt.client as mqtt # The callback for when the client receives a CONNACK response from the server. def on_connect(client, userdata, rc): client.subscribe("GB/node0/", 2) # The callback for when a PUBLISH message is received from the server. def on_message(client, userdata, msg): print "Topic: ", msg.topic+'\nMessage: '+str(msg.payload) client = mqtt.Client() client.on_connect = on_connect client.on_message = on_message client.connect("192.168.15.4", 1883, 60) # Blocking call that processes network traffic, dispatches callbacks and # handles reconnecting. client.loop_forever()
As you noticed in client.subscribe (), the QoS is 2. This is the only modification of the official document.
Publishing client code -
#PUBLISHER import paho.mqtt.client as mqtt mqttc = mqtt.Client("python_pub") mqttc.connect("192.168.15.4", 1883, 60) mqttc.publish("GB/node0/", "Hello, World baby!",2)
Here also the QoS is 2.
This QoS modification results in only 20 messages being received by the subscriber. Upon further testing, I realized that the problem was probably related to
, which is an optional function that sets the maximum number of messages with QoS> 0 that can be part of the path through the network stream at once. The default is 20.
However, changing it to any other value does not work. Also, why does the client think these messages are still in sight when they are received? How to solve a problem? How can I be sure that the customer understands that these messages are not "highlighted" and have been delivered?
source to share
@hardillb is right, you need some form of invocation
. To be more confident, do the following:
import paho.mqtt.client as mqtt def on_publish(client, userdata, mid): client.disconnect() mqttc = mqtt.Client() # There normally no need to set a client id. mqttc.on_publish = on_publish mqttc.connect("192.168.15.4", 1883, 60) mqttc.publish("GB/node0/", "Hello, World baby!",2) mqttc.loop_forever()
import paho.mqtt.publish as paho paho.single("GB/node0/", "Hello, World baby!", qos=2, hostname="192.168.15.4")
source to share