def METHOD_NAME(self):
    self.is_running = True
    # the first message after connection, aligned the protocol with MQTT + S3
    self._notify_connection_ready()
    start_listening_time = time.time()
    MLOpsProfilerEvent.log_to_wandb({"ListenStart": start_listening_time})
    while self.is_running:
        if self.q_receiver.qsize() > 0:
            message_handler_start_time = time.time()
            msg_params = self.q_receiver.get()
            self.notify(msg_params)
            MLOpsProfilerEvent.log_to_wandb(
                {"BusyTime": time.time() - message_handler_start_time}
            )
        time.sleep(0.0001)
    MLOpsProfilerEvent.log_to_wandb(
        {"TotalTime": time.time() - start_listening_time}
    )
    logging.info("!!!!!!handle_receive_message stopped!!!")