diff --git a/dxlclient/_request_manager.py b/dxlclient/_request_manager.py index 72d13ae..188b9fc 100644 --- a/dxlclient/_request_manager.py +++ b/dxlclient/_request_manager.py @@ -229,7 +229,7 @@ def on_response(self, response): if request_message_id in self.sync_wait_message_ids: self.sync_wait_message_ids.remove(request_message_id) self.sync_wait_message_responses[request_message_id] = response - self.sync_wait_message_condition.notifyAll() + self.sync_wait_message_condition.notify_all() # Check for asynchronous callbacks callback = self.unregister_async_callback(request_message_id) diff --git a/dxlclient/client.py b/dxlclient/client.py index 9905e6a..57d84cb 100644 --- a/dxlclient/client.py +++ b/dxlclient/client.py @@ -605,7 +605,7 @@ def _disconnect(self): logger.debug("Waiting for the thread to terminate...") self._thread_terminate = True with self._connect_wait_lock: - self._connect_wait_condition.notifyAll() + self._connect_wait_condition.notify_all() while self._thread.is_alive(): self._thread.join(1) self._thread = None @@ -944,7 +944,7 @@ def sync_request(self, request, timeout=_DEFAULT_WAIT): to the request. If the timeout is exceeded an exception will be raised. Defaults to ``3600`` seconds (1 hour) """ - if threading.currentThread().name.startswith(self._message_pool_prefix): + if threading.current_thread().name.startswith(self._message_pool_prefix): raise DxlException("Synchronous requests may not be invoked while handling an incoming message. " + "The synchronous request must be made on a different thread.")