def METHOD_NAME():
    mqtt_client = paho.Client(transport="websockets", client_id="server")
    mqtt_client.enable_logger()
    mqtt_client.username_pw_set(username="tavern", password="tavern")
    mqtt_client.connect(host="broker", port=9001)
    try:
        mqtt_client.loop_start()
        yield mqtt_client
    finally:
        mqtt_client.disconnect()
        mqtt_client.loop_stop()