diff --git a/communicator.py b/communicator.py index 8328ad1..be1fc67 100644 --- a/communicator.py +++ b/communicator.py @@ -43,11 +43,14 @@ class Communicator: Get the list of available consumer from the current primary consumer. :return: """ - currentconsumer = self.currenctconsumer - response = requests.get(f'http://{currentconsumer}/consumer') - json = response.json() - LOGGER.debug(f"List of currently available consumers: {json}") - return json + try: + currentconsumer = self.currenctconsumer + response = requests.get(f'http://{currentconsumer}/consumer') + json = response.json() + LOGGER.debug(f"List of currently available consumers: {json}") + return json + except Exception: + return [] def isconsumeravailable(self) -> bool: """