Simple Akka scheduler actor

import akka.actor.{ Actor, Scheduler }
import java.util.concurrent.TimeUnit.SECONDS

class SimpleSchedulerActor extends Actor {
override def preStart = {
Scheduler.schedule(self, “a message”, 0, 60, SECONDS)
}
def receive = {
case x => println(“Got: ” + x)
}
}

Actor.actorOf[SimpleSchedulerActor].start

Advertisements

Leave a Reply

Fill in your details below or click an icon to log in:

WordPress.com Logo

You are commenting using your WordPress.com account. Log Out / Change )

Twitter picture

You are commenting using your Twitter account. Log Out / Change )

Facebook photo

You are commenting using your Facebook account. Log Out / Change )

Google+ photo

You are commenting using your Google+ account. Log Out / Change )

Connecting to %s