queue.py 文件源码

def get(self, retry = 2):
        try:
            method_frame, properties, body = self._channel.basic_get(self._queue_name, no_ack=True)
            if not body:
                return

            return json.loads(body)

        except exceptions.ConnectionClosed as err:
            if retry <= 0:
                raise err

            self.open()
            return self.get(retry - 1)