From 6a2ab18c84da60672d32d14ac7a06e71734caf1f Mon Sep 17 00:00:00 2001
From: Thomas Williams <thomas@ycwmwl.cymru>
Date: Sat, 17 Aug 2024 10:43:49 +0100
Subject: [PATCH] Moved retry logic

---
 rabbitmq.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/rabbitmq.py b/rabbitmq.py
index 41922f8..fe01cc6 100644
--- a/rabbitmq.py
+++ b/rabbitmq.py
@@ -41,9 +41,9 @@ class rabbitMQClient:
         self.rabbitmqPort = rabbitmqPort
         self.routingKey = routingKey
 
+    @retry(stop_max_attempt_number=120, wait_fixed=1000)
     def publish(self, message):
 
-        @retry(stop_max_attempt_number=120, wait_fixed=1000)
         def publishMessage(conn):
 
             ch = conn.channel()