Searched refs:existing_queue (Results 1 – 3 of 3) sorted by relevance
111 existing_queue=None, argument161 if existing_queue is not None:163 if type(existing_queue) == str:164 if existing_queue in self._registered_mirrors:166 existing_queue].dataType168 existing_queue].sync170 existing_queue].queueId175 elif isinstance(existing_queue, resource_mirror.ResourceFmqMirror):176 data_type = existing_queue.dataType177 sync = existing_queue.sync[all …]
92 existing_queue=self._queue1_writer,110 existing_queue=self._queue2_writer,128 existing_queue=self._queue3_writer,136 existing_queue=self._queue3_writer,158 existing_queue=self._queue4_writer,
120 existing_queue=self._unsync_client1,