thomas/monutil
1
0
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Wiki Activity Actions

Moved retry logic

Browse source
This commit is contained in:
Thomas Williams 2024-08-17 10:43:49 +01:00
parent 5de96c7b04
commit 6a2ab18c84
Signed by: thomas
GPG key ID: EB8F975CF60BCBFF
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
rabbitmq.py
View file

@ -41,9 +41,9 @@ class rabbitMQClient:
self.rabbitmqPort = rabbitmqPort self.rabbitmqPort = rabbitmqPort
self.routingKey = routingKey self.routingKey = routingKey
@retry(stop_max_attempt_number=120, wait_fixed=1000)
def publish(self, message): def publish(self, message):
@retry(stop_max_attempt_number=120, wait_fixed=1000)
def publishMessage(conn): def publishMessage(conn):
ch = conn.channel() ch = conn.channel()