- signal.signal(signal.SIGALRM, _handle_timeout)
- signal.alarm(timeout)
-
- res = None
- try:
- method = None
- i = 0
- while method is None:
- method, properties, body = self.channel.basic_get(queues[i])
- if i == len(queues) - 1:
- i = 0
- else:
- i += 1
- res = Message(self, method, properties, body)
- finally:
- signal.alarm(0)
-
- return res
+ else:
+ return Message(self, method, properties, body)