|
@@ -88,6 +88,7 @@ class mqtt_client(object):
|
88
|
88
|
logger.warning("Disconnect with rc=%s", repr(rc))
|
89
|
89
|
|
90
|
90
|
def __receive__(self, client, userdata, message):
|
|
91
|
+ message.mid = self.__client__._mid_generate() # add a message id to the received message
|
91
|
92
|
get_topic_logger(message.topic).debug("Received message with topic %s and payload %s", message.topic, str(message.payload))
|
92
|
93
|
for topic in self.__callbacks__.copy():
|
93
|
94
|
if topic.endswith('#'):
|