'Remove from transactional state and requeue message.'

def reject(self, delivery_tag, requeue=False):

    if requeue:
        self.channel._restore_at_beginning(self._delivered[delivery_tag])
    self._quick_ack(delivery_tag)
