def _create_process_thread(self):
        thread = threading.Thread(target=self._process_data_events)
        thread.setDaemon(True)
        thread.start()
Create a thread responsible for consuming messages in response
dataset/ETHPy150Open eandersson/amqpstorm/examples/flask_threaded_rpc_client.py/RpcClient._create_process_thread