continue trying connect on ping error
This commit is contained in:
parent
75ce9067dc
commit
6d0dfd4dc8
@ -252,11 +252,11 @@ class ExternalMessageConsumer:
|
|||||||
|
|
||||||
continue
|
continue
|
||||||
except Exception:
|
except Exception:
|
||||||
logger.info(
|
logger.error(
|
||||||
f"Ping error {channel} - retrying in {self.sleep_time}s")
|
f"Ping error {channel} - retrying in {self.sleep_time}s")
|
||||||
await asyncio.sleep(self.sleep_time)
|
await asyncio.sleep(self.sleep_time)
|
||||||
|
|
||||||
break
|
continue
|
||||||
|
|
||||||
def handle_producer_message(self, producer: Dict[str, Any], message: Dict[str, Any]):
|
def handle_producer_message(self, producer: Dict[str, Any], message: Dict[str, Any]):
|
||||||
"""
|
"""
|
||||||
|
Loading…
Reference in New Issue
Block a user