small fix

NeonGeckoCom · Nov 25, 2024 · f765e22 · f765e22
1 parent 9f63357
commit f765e22
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py
@@ -546,7 +546,7 @@ def stop_consumers(self, names: tuple = (), allow_restart: bool = True):
             names = list(self.consumers)
         for name in names:
             try:
-                if isinstance(self.consumers.get(name), SUPPORTED_THREADED_CONSUMERS):
+                if isinstance(self.consumers.get(name), SUPPORTED_THREADED_CONSUMERS) and self.consumers[name].is_alive():
                     self.consumers[name].join(timeout=self.__consumer_join_timeout__, allow_restart=allow_restart)
                     self.consumer_properties[name]['is_alive'] = self.consumers[name].is_consumer_alive
                     self.consumer_properties[name]['started'] = False