Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class child extends Actor {
- def receive = {
- case insertData(data) =>
- //insertion code ,MongoTimeOutException is raised i have killed the service intentionally
- }
- }
- class parent extends Actor {
- val child=context.actorOf.....//actor creation code
- override val supervisorStrategy = OneForOneStrategy(
- maxNrOfRetries = 10, withinTimeRange = 10 seconds) {
- case _:MongoException=>
- log.error("Got some MongosException, Supervision Strategy says Resume")
- Resume
- case _:ElasticsearchTimeoutException=>
- log.error("Got some ElasticsearchTimeoutException, Supervision Strategy says Resume")
- Resume
- case _:ElasticsearchException=>
- log.error("Got some ElasticsearchException, Supervision Strategy says Resume")
- Resume
- case _ =>
- log.error("Got some Exception, Supervision Strategy says Resume")
- Resume
- }
- def receive = {
- case Msg(data) =>
- child ! insertData(data)
- }
- }
- object test extends App
- {
- val parent = system.actorof....//actor creation code
- parent !Msg(data)
- }
- case _ =>
- log.error("Got some Exception, Supervision Strategy says Resume")
- Resume
- case _:MongoException=>
- log.error("Got some MongosException, Supervision Strategy says Resume")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement