diff --git a/__init__.py b/__init__.py index 5b12c55..b853f6e 100644 --- a/__init__.py +++ b/__init__.py @@ -65,6 +65,8 @@ class mqtt_client(object): self.__client__.subscribe(topic) def send(self, topic, payload): + logger.debug("Sending message with topic %s and payload %s", + topic, str(payload)) self.__client__.publish(topic, payload) def __on_connect__(self, client, userdata, flags, rc): @@ -75,7 +77,7 @@ class mqtt_client(object): for topic in self.__callbacks__: self.__client__.subscribe(topic) self.__block_add_callbacks__ = False - + def __on_disconnect__(self, client, flags, rc): logger.warning("Disconnect with rc=%d", rc)