Планировщик с долгоживущим актором

ConfirmationCodeCleanTask.scala

class ConfirmationCodeCleanTask(
  val connection: DBConnection
) extends ServiceActor
    with RegistrationConfirmation
    with ActorLogging {

  override def process: Receive = {
    case ConfirmationCodeCleanTask.Start =>
      deleteExpired()
  }
}

object ConfirmationCodeCleanTask extends ClassActorName {

  sealed trait Command
  case object Start                  extends Command
  case class Done(replyTo: ActorRef) extends Command

  // safe constructor
  def props(
    connection: DBConnection
  ): ActorProps =
    ActorProps(Props(new ConfirmationCodeCleanTask(connection)), name)
}

UserScheduler.scala

class UserScheduler(val connection: DBConnection, val settings: Settings) extends ServiceActor {

  override def process: Receive = Actor.emptyBehavior

  val codeCleanerProps: ActorProps = ConfirmationCodeCleanTask.props(connection)
  val codeCleaner: ActorRef        = context.actorOf(codeCleanerProps.props, codeCleanerProps.name)

  override def preStart(): Unit = {
    super.preStart()
    initCodeCleaner()
  }

  def initCodeCleaner(duration: Duration = settings.Registration.clearPeriod): Unit = {
    val finPeriod = FiniteDuration(duration.toSeconds, TimeUnit.SECONDS)
    context.system.scheduler.schedule(finPeriod, finPeriod, codeCleaner, ConfirmationCodeCleanTask.Start)
  }
}

object UserScheduler extends ClassActorName {

  sealed trait Command
  case object Start extends Command

  // safe constructor
  def props(
    connection: DBConnection,
    settings: Settings
  ): ActorProps =
    ActorProps(Props(new UserScheduler(connection, settings)), name)
}