A simple way to implement Retry Support For Akka Future in Scala


[Note: This blog has been updated on 22nd August 2013, after the valuable feedback of readers.]
In this blog, I have explained a simple way to implement retry support for Akka future in Scala.
When Akka actor dies for any reason and we try to receive response from Akka future, this implementation would work.

Here is the logic:

object RetrySupport  {

  def retry(actorRef: ActorRef, message: Any, maxAttempts: Int, attempt: Int): Future[Any] = {
    val future = (actorRef ? message) recover {
      case e: AskTimeoutException =>
        if (attempt <= maxAttempts) retry(actorRef, message, maxAttempts, attempt + 1)
        else None // Return default result according to your requirement, if actor is non-reachable.
    }
    future
  }
}

When Akka future fails to respond, this retry logic would start automatically and would work until result is obtained or until number of retry limit is finished.
If we would not provide any limit, this would work indefinitely until result is obtained.

A sample call to this method :-

retry(actor, message, 10, 0)

Here number of retry limit is 10. So above call would hit retry method 10 times. If limit is over and actor is not reachable, retry method would return None as future response.

You can return default result according to your requirement.

After getting Future, you can use the mapTo method to safely cast a Future to an expected type. This will return the result, if the cast is successful. Otherwise it will return ClassCastException.

If you have implemented any better approach, please suggest.

Any suggestion would be appreciated.

About these ads

About ayushmishra2005

Ayush is the Sr. Software Consultant @ Knoldus Software LLP. In his 5 years of experience he has become developer with proven experience in architecting and developing web applications. Ayush has a Masters in Computer Application from U.P. Technical University, Ayush is a strong-willed and self-motivated professional who takes deep care in adhering to quality norms within projects. He is capable of managing challenging projects with remarkable deadline sensitivity without compromising code quality. .
This entry was posted in Akka, Scala, Web. Bookmark the permalink.

7 Responses to A simple way to implement Retry Support For Akka Future in Scala

  1. Nirmalya Sengupta says:

    May be I am missing something obvious, but what is the parameter value ‘true’ being used for?

  2. Hi Nirmalya,

    Thanks for pointing out. I have corrected this. Please check.

  3. Viktor Klang says:

    You can avoid the blocking/Await by using Pattern.after + recoverWith.

    • Hi Viktor,

      Thanks for your valuable feedback. I completely agree with your point. We should always avoid Await.result unless there is a very specific reason to use this.

      I used this because I had a very specific reason to use this. It was my bad that I have not mentioned this anywhere in my blog. I would mention the reason to use Await in my another Blog.

  4. “Await” is a sign of bad thing. “Everything is an object” is not always good. I wish every processing unit is an actor, just like in Erlang.

  5. Hello Guys,

    Thanks for your valuable comments. I have updated the blog. Please check and let me know if still you find any issue.

    Your comments would be appreciated.

Leave a Reply

Fill in your details below or click an icon to log in:

WordPress.com Logo

You are commenting using your WordPress.com account. Log Out / Change )

Twitter picture

You are commenting using your Twitter account. Log Out / Change )

Facebook photo

You are commenting using your Facebook account. Log Out / Change )

Google+ photo

You are commenting using your Google+ account. Log Out / Change )

Connecting to %s