diff --git a/service.py b/service.py
index 2d46a9a..0754ff7 100644
--- a/service.py
+++ b/service.py
@@ -223,8 +223,12 @@ class Appservice:
 def receive_messages(
     appservice: Appservice, msg_queue: message_queue.MessageQueue
 ):
-    for message in msg_queue:
-        appservice.process_message(message)
+    while True:
+        try:
+            for message in msg_queue:
+                appservice.process_message(message)
+        except Exception as e:
+            LOG.exception(e)
 
 
 def main():