INNER CODE UNIT · Python
__init__
sabuhish/fastapi-mqtt · fastapi_mqtt/handlers.py:18
def __init__(self, client: MQTTClient, logger: Logger):
self._logger = logger
self.client = client
self.user_message_handler: Optional[MQTTMessageHandler] = None
self.user_connect_handler: Optional[MQTTConnectionHandler] = None
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