diff --git a/__init__.py b/__init__.py
index 88118d4..f985791 100644
--- a/__init__.py
+++ b/__init__.py
@@ -88,6 +88,7 @@ class mqtt_client(object):
         logger.warning("Disconnect with rc=%s", repr(rc))
 
     def __receive__(self, client, userdata, message):
+        message.mid = self.__client__._mid_generate()	# add a message id to the received message
         get_topic_logger(message.topic).debug("Received message with topic %s and payload %s", message.topic, str(message.payload))
         for topic in self.__callbacks__.copy():
             if topic.endswith('#'):