Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val clusterManager = ClusterSingletonManager.props(
- singletonProps = Props(classOf[PushWorker]),
- singletonName = "pushWorkerSingleton",
- terminationMessage = PoisonPill.getInstance,
- role = None
- )
- val pushActor = Akka.system(app).actorOf(clusterManager, "pushWorker")
- Akka.system(app).scheduler.schedule(10 seconds, 10 seconds, pushActor, "pushWorker")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement