Schedule a Job in Play With Akka

Greetings to all!

In this blog, we will see how we can schedule a job after some time period in play using Scala. Before we get started, I'm assuming you all have a little knowledge of Akka, Play, and Scala.

So here, we start with an actor where we will write our job to be scheduled as follows:

import javax.inject.{Inject, Singleton}
import akka.actor.Actor
import play.api.Logger
import scala.concurrent.ExecutionContext
@Singleton
class JobSchedulerActor @Inject()(implicit ec: ExecutionContext) extends Actor {
    var c= 0
    override def receive: Receive = {
        case _ =>
        c = c+1
        Logger.info("Job Scheduled "+ c )
        //Here put your code for your job
    }
}

Now, we will define the scheduler for the above job to execute at a certain duration:

class Scheduler @Inject() (val system: ActorSystem, @Named("<strong>JobSchedulerActor</strong>") val j<strong>obSchedulerActor</strong>: ActorRef)(implicit ec: ExecutionContext) {
    var actor = system.scheduler.schedule(
    0.seconds, 30.seconds,JobSchedulerActor, "schedule")
}

Now we need to bind the actor and scheduler:

import actor.SchedulerActor
import com.google.inject.AbstractModule
import play.api.Logger
import play.api.libs.concurrent.AkkaGuiceSupport
import scheduler.Scheduler

class BindModule extends AbstractModule with AkkaGuiceSupport {
    def configure() = {
        Logger.info("\nConfigurring Scheduler.")
        bindActor[<strong>JobSchedulerActor</strong>]("<strong>JobSchedulerActor</strong>")
        bind(classOf[Scheduler]).asEagerSingleton()
    }
}

Now we tell Play to start the actor after the scheduled time. We only need to write the following configuration inside application.conf :

play.modules.enabled += "modules.BindModule"

And with that, your scheduler will start scheduling your job after the specified duration once your server is up.