change scope for retry consume

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()