code: def _create_process_thread(self):
          
          thread = threading.Thread(target=self._process_data_events)
          thread.setDaemon(True)
          thread.start()
docs: Create a thread responsible for consuming messages in response
           to RPC requests.