def basic_recover(self, requeue=False):
        with _CallbackResult() as recover_ok_result:
            self._impl.basic_recover(callback=recover_ok_result.signal_once,
                                     requeue=requeue)
            self._flush_output(recover_ok_result.is_ready)
This method asks the server to redeliver all unacknowledged messages
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingChannel.basic_recover