t_start = time.time()
method = None
i = 0
+ delay = 0.0
while method is None and (time.time()-t_start < timeout or timeout <= 0):
- time.sleep(0.1)
+ time.sleep(delay)
+ if delay < 1:
+ delay += 0.01
method, properties, body = self.channel.basic_get(queues[i])
if i == len(queues) - 1:
i = 0