Commit 5b753911 authored by Georgios Gousios's avatar Georgios Gousios
Browse files

Survive server restarts

parent 2589bb1b
......@@ -48,6 +48,9 @@ class Dispatcher:
self.chan.wait()
except SystemExit:
break
except amqp.exceptions.AMQPConnectionException:
self.logger.error("Server went away, reconnecting...")
self._init()
except socket.error:
self.logger.error("Server went away, reconnecting...")
self._init()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment