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