Use is_alive in favour of isAlive for Python 3.9 compatibility.

pulsar/managers/queued.py

@@ -71,7 +71,7 @@ def shutdown(self, timeout=None):
             self.work_queue.put((STOP_SIGNAL, None))
         for worker in self.work_threads:
             worker.join(timeout)
-            if worker.isAlive():
+            if worker.is_alive():
                 log.warn("Failed to stop worker thread [%s]" % worker)
 
     def run_next(self):

pulsar/managers/stateful.py

@@ -342,7 +342,7 @@ def __init__(self, stateful_manager):
     def shutdown(self, timeout=None):
         self.active = False
         self.thread.join(timeout)
-        if self.thread.isAlive():
+        if self.thread.is_alive():
             log.warn("Failed to join monitor thread [%s]" % self.thread)
 
     def _run(self):

pulsar/messaging/__init__.py

@@ -39,7 +39,7 @@ def __nonzero__(self):
     def join(self, timeout=None):
         for t in self.threads:
             t.join(timeout)
-            if t.isAlive():
+            if t.is_alive():
                 log.warn("Failed to join thread [%s]." % t)