def consume(self, limit=None):
        """Consume from all queues/consumers"""
        it = self.iterconsume(limit=limit)
        while True:
            try:
                it.next()
            except __HOLE__:
                return
dataset/ETHPy150Open nii-cloud/dodai-compute/nova/rpc/impl_kombu.py/Connection.consume