Akka Actor Retry on Failure

Question

У меня есть Актер, получивший сообщение Init и после получения этого сообщения он пытается создать соединение с внешней службой. Теперь эта связь может добиться успеха или потерпеть неудачу, и я знаю эту информацию в моем Актер:

def receive = { 
    case Init => { 
    val someConn: Option[Connection] = createConnection(...) 
    someConn match { 
     case Some(conn) => { 
     // do something 
     } 
     case None => // I want to re-try Init, but after a few seconds delay! 
    } 
} 

После None, я хотел бы, чтобы отправить сообщение само к этому актеру с сообщением инициализации снова, но я не хотел бы делать это немедленно. Я хотел бы иметь задержку в несколько секунд, скажем, 10 секунд. Какие-либо предложения?

Answer 1

Вы можете отправить сообщение для себя один раз, на задержку, используя scheduleOnce см мой ответ здесь:

https://stackoverflow.com/a/31658345/5142537

context.system.scheduler.scheduleOnce(10 seconds, self, Init)