Advertisement
Guest User

Untitled

a guest
Oct 27th, 2016
61
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.26 KB | None | 0 0
  1. class child extends Actor {
  2. def receive = {
  3. case insertData(data) =>
  4. //insertion code ,MongoTimeOutException is raised i have killed the service intentionally
  5. }
  6. }
  7.  
  8. class parent extends Actor {
  9.  
  10. val child=context.actorOf.....//actor creation code
  11.  
  12. override val supervisorStrategy = OneForOneStrategy(
  13. maxNrOfRetries = 10, withinTimeRange = 10 seconds) {
  14. case _:MongoException=>
  15. log.error("Got some MongosException, Supervision Strategy says Resume")
  16. Resume
  17. case _:ElasticsearchTimeoutException=>
  18. log.error("Got some ElasticsearchTimeoutException, Supervision Strategy says Resume")
  19. Resume
  20. case _:ElasticsearchException=>
  21. log.error("Got some ElasticsearchException, Supervision Strategy says Resume")
  22. Resume
  23. case _ =>
  24. log.error("Got some Exception, Supervision Strategy says Resume")
  25. Resume
  26. }
  27.  
  28. def receive = {
  29. case Msg(data) =>
  30. child ! insertData(data)
  31. }
  32. }
  33.  
  34. object test extends App
  35. {
  36. val parent = system.actorof....//actor creation code
  37. parent !Msg(data)
  38. }
  39.  
  40. case _ =>
  41. log.error("Got some Exception, Supervision Strategy says Resume")
  42. Resume
  43.  
  44. case _:MongoException=>
  45. log.error("Got some MongosException, Supervision Strategy says Resume")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement