Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- imports:
- import akka.pattern.ask
- import akka.util.Timeout
- import scala.concurrent.duration._
- import scala.util.{Failure, Success}
- import scala.concurrent.ExecutionContext.Implicits.global
- code:
- implicit val _timeout = Timeout(5000.milliseconds)
- val f = worker ? DoWork(work)
- f.onComplete{
- case Success(result) => log.info("good")
- case Failure(result) => log.info("bad")
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement