async def METHOD_NAME(self, payload: dict, in_edge=None):
    try:
        async with aiomqtt.Client(self.credentials.url,
                                  port=self.credentials.port,
                                  username=self.credentials.username,
                                  password=self.credentials.password) as client:
            await client.publish(
                self.config.topic,
                payload=self.config.payload.encode(),
                qos=int(self.config.qos),
                retain=self.config.retain
            )
        return Result(port="payload", value=payload)
    except Exception as e:
        return Result(port="error", value={
            "message": str(e)
        })