Error in mqtt async example

[lsrur]

I get the following error when running the async mqtt example:

Exception in message_received when handling msg on 'home-assistant/mqtt_example': 'payload_text' TypeError: async_setup.<locals>.message_received() missing 2 required positional arguments: 'payload' and 'qos'

Any ideas?
TIA

[fflori4n]

Hey,
Ran into the same issue today, it seems that the message_received() function was changed at some point, and now expects a ReceiveMessage type object that contains all the previous arguments. Managed to do a quick and dirty fix to get the integration working, just by replacing :

def message_received(topic: str, payload: str, qos: int)  -> None:

with:

def message_received(args: ReceiveMessage) -> None:

       # logging.warning(args)  #just log the object to see how it looks

        topic = getattr(args, 'topic')
        payload = getattr(args, 'payload')
        qos = getattr(args, 'qos')

[bigmoby]

https://developers.home-assistant.io/blog/2023/02/21/deprecated-callback-removed/