add catch for invalid message error
This commit is contained in:
parent
128b117af6
commit
77ed713232
@ -212,7 +212,8 @@ class ExternalMessageConsumer:
|
|||||||
except (
|
except (
|
||||||
socket.gaierror,
|
socket.gaierror,
|
||||||
ConnectionRefusedError,
|
ConnectionRefusedError,
|
||||||
websockets.exceptions.InvalidStatusCode
|
websockets.exceptions.InvalidStatusCode,
|
||||||
|
websockets.exceptions.InvalidMessage
|
||||||
) as e:
|
) as e:
|
||||||
logger.error(f"Connection Refused - {e} retrying in {self.sleep_time}s")
|
logger.error(f"Connection Refused - {e} retrying in {self.sleep_time}s")
|
||||||
await asyncio.sleep(self.sleep_time)
|
await asyncio.sleep(self.sleep_time)
|
||||||
@ -224,7 +225,7 @@ class ExternalMessageConsumer:
|
|||||||
continue
|
continue
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
# An unforseen error has occurred, log and stop
|
# An unforseen error has occurred, log and continue
|
||||||
logger.error("Unexpected error has occurred:")
|
logger.error("Unexpected error has occurred:")
|
||||||
logger.exception(e)
|
logger.exception(e)
|
||||||
continue
|
continue
|
||||||
|
Loading…
Reference in New Issue
Block a user