INNER CODE UNIT · Python

on_message

sabuhish/fastapi-mqtt · fastapi_mqtt/handlers.py:24

    def on_message(self, handler: MQTTMessageHandler) -> MQTTMessageHandler:
        self._logger.info("on_message handler accepted")
        self.user_message_handler = handler
        return handler

    def on_subscribe(self, handler: MQTTSubscriptionHandler) -> MQTTSubscriptionHandler:
        """
        Decorator method is used to obtain subscribed topics and properties.
        """
        self._logger.info("on_subscribe handler accepted")
        self.client.on_subscribe = handler
        return handler

    def on_disconnect(self, handler: MQTTDisconnectHandler) -> MQTTDisconnectHandler:
        self.client.on_disconnect = handler
        return handler

    def on_connect(self, handler: MQTTConnectionHandler) -> MQTTConnectionHandler:

View source record →