Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class RunningActors extends Actor with ActorLogging {
- def receive = {
- case "start" =>
- log.info("Current Actors in system:")
- self ! ActorPath.fromString("akka://Streams/user/")
- case path: ActorPath =>
- context.actorSelection(path / "*") ! Identify(())
- case ActorIdentity(_, Some(ref)) =>
- log.info(ref.toString())
- self ! ref.path
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement