diff --git a/src/serve.py b/src/serve.py
index 1948abf..7e26ce4 100644
--- a/src/serve.py
+++ b/src/serve.py
@@ -54,11 +54,11 @@ def main():
 
     @retry(ConsumerError, tries=3, delay=5, jitter=(1, 3))
     def consume():
+        consumer = Consumer(visitor, queue_manager)
         try:
-            consumer = Consumer(visitor, queue_manager)
             consumer.consume_and_publish()
         except Exception as err:
-            raise ConsumerError from err
+            raise ConsumerError() from err
 
     try:
         consume()