def METHOD_NAME(self) -> None:
    if self.__processed_messages < self.__num_messages_to_process:
        logger.warning(
            "Closing DLQ consumer after %d messages", self.__processed_messages
        )
    self.__next_step.METHOD_NAME()