i don't know how to pass the correct parameters in this version

[ndertaker]

This is my _messenger_queue_publish()

def _messenger_queue_publish(client: mqtt.Client, userdata, rc): topics = None

           queue = {
                "sync_api_version": 10,
                "max_deltas_able_to_process": 1000,
                "delta_batch_size": 500,
                "encoding": "JSON",
                "entity_fbid": self.dataFB['FacebookID']
           }

           if (self.syncToken == None):
                topics = "/messenger_sync_create_queue"
                queue["initial_titan_sequence_id"] = self.lastSeqID
                queue["device_params"] = None
           else:
                topics = "/messenger_sync_get_diffs"
                queue["last_seq_id"] = self.lastSeqID
                queue["sync_token"] = "1"

           client.publish(
                topics,
                json_minimal(queue),
                qos=1,
                retain=False,
           )

self.mqtt = mqtt.Client( mqtt.CallbackAPIVersion.VERSION2, client_id=options["client_id"], clean_session=options["clean"], protocol=mqtt.MQTTv31, transport="websockets", )

      self.mqtt.tls_set(certfile=None, keyfile=None, cert_reqs=ssl.CERT_NONE, tls_version=ssl.PROTOCOL_TLSv1_2)

      self.mqtt.on_connect = _messenger_queue_publish
      self.mqtt.on_message = on_message
      self.mqtt.on_disconnect = on_disconnect

      self.mqtt.username_pw_set(username=options["username"])
      parsed_host = urlparse(host)

      self.mqtt.ws_set_options(
           path=f"{parsed_host.path}?{parsed_host.query}",
           headers=options["ws_options"]["headers"],
      )

      # connect
      self.mqtt.connect(
           host=options["ws_options"]["headers"]["Host"],
           port=443,
           keepalive=options["keepalive"],
      )
      self.mqtt.loop_forever()

The error: Traceback (most recent call last): File "/storage/emulated/0/Download/lon/listen.py", line 202, in _.connect_mqtt() File "/storage/emulated/0/Download/lon/listen.py", line 196, in connect_mqtt self.mqtt.loop_forever() File "/data/data/com.termux/files/usr/lib/python3.11/site-packages/paho/mqtt/client.py", line 2297, in loop_forever rc = self._loop(timeout) ^^^^^^^^^^^^^^^^^^^ File "/data/data/com.termux/files/usr/lib/python3.11/site-packages/paho/mqtt/client.py", line 1686, in _loop rc = self.loop_read() ^^^^^^^^^^^^^^^^ File "/data/data/com.termux/files/usr/lib/python3.11/site-packages/paho/mqtt/client.py", line 2100, in loop_read rc = self._packet_read() ^^^^^^^^^^^^^^^^^^^ File "/data/data/com.termux/files/usr/lib/python3.11/site-packages/paho/mqtt/client.py", line 3142, in _packet_read rc = self._packet_handle() ^^^^^^^^^^^^^^^^^^^^^ File "/data/data/com.termux/files/usr/lib/python3.11/site-packages/paho/mqtt/client.py", line 3814, in _packet_handle return self._handle_connack() ^^^^^^^^^^^^^^^^^^^^^^ File "/data/data/com.termux/files/usr/lib/python3.11/site-packages/paho/mqtt/client.py", line 3934, in _handle_connack on_connect( TypeError: listeningEvent.connect_mqtt.._messenger_queue_publish() takes 3 positional arguments but 5 were given