def restart(self):
    restart_all_messages = not self.filters
    while True:
        if not restart_all_messages and not self.filters:
            return

        messages = self._retrieve_messages()
        if not messages:
            return

        if not restart_all_messages:
            messages = self._filter_messages(messages)
            self.filters = [id for id in self.filters if id not in [msg.id for msg in messages]]

        send_sqs_message_batch(messages, self.queue_url)
        delete_sqs_message_batch(messages, self.dlt_queue_url)