Advertisement
Guest User

Untitled

a guest
Nov 25th, 2015
63
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.37 KB | None | 0 0
  1. class RunningActors extends Actor with ActorLogging {
  2.  
  3. def receive = {
  4. case "start" =>
  5. log.info("Current Actors in system:")
  6. self ! ActorPath.fromString("akka://Streams/user/")
  7.  
  8. case path: ActorPath =>
  9. context.actorSelection(path / "*") ! Identify(())
  10.  
  11. case ActorIdentity(_, Some(ref)) =>
  12. log.info(ref.toString())
  13. self ! ref.path
  14. }
  15. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement