'Recover unacked messages.'

def basic_recover(self, requeue=False):

    if requeue:
        return self.qos.restore_unacked()
    raise NotImplementedError(u'Does    not    support    recover(requeue=False)')
