Advertisement
Guest User

Untitled

a guest
Aug 12th, 2014
156
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.41 KB | None | 0 0
  1.       val clusterManager = ClusterSingletonManager.props(
  2.         singletonProps = Props(classOf[PushWorker]),
  3.         singletonName = "pushWorkerSingleton",
  4.         terminationMessage = PoisonPill.getInstance,
  5.         role = None
  6.       )
  7.       val pushActor = Akka.system(app).actorOf(clusterManager, "pushWorker")
  8.       Akka.system(app).scheduler.schedule(10 seconds, 10 seconds, pushActor, "pushWorker")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement