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