fix: rabbitmq retry

sdk/RabbitMQ.py

@@ -3,7 +3,7 @@
 # @Author : XuJiakai
 # @File : RabbitMQ
 # @Software: PyCharm
-
+from retry import retry
 import pika
 import json
 import os
@@ -36,6 +36,7 @@ class RabbitMQ(object):
                                       credentials=credentials))
         self.channel = self.connect.channel()  # 客户端连接rabbitmq服务端后开辟管道，每个channel代表一个会话任务
 
+    @retry(delay=5, jitter=(1, 3))
     def send_by_fanout(self, exchange, body):
         """
         多消费、重复订阅方式
@@ -58,6 +59,7 @@ class RabbitMQ(object):
         )
         pass
 
+    @retry(delay=5, jitter=(1, 3))
     def consumer_by_fanout(self, exchange, callback=_default_callback):
         """
         消费、扇出模式