Package org.apache.curator

Class SessionFailedRetryPolicy

java.lang.Object
org.apache.curator.SessionFailedRetryPolicy
All Implemented Interfaces:
RetryPolicy
public class SessionFailedRetryPolicy extends Object implements RetryPolicy
RetryPolicy implementation that failed on session expired.

  • Constructor Details

    • SessionFailedRetryPolicy

      public SessionFailedRetryPolicy(RetryPolicy delegatePolicy)

  • Method Details

    • allowRetry

      public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper)
      Description copied from interface: RetryPolicy
      Called when an operation has failed for some reason. This method should return true to make another attempt.
      Specified by:
      allowRetry in interface RetryPolicy
      Parameters:
      retryCount - the number of times retried so far (0 the first time)
      elapsedTimeMs - the elapsed time in ms since the operation was attempted
      sleeper - use this to sleep - DO NOT call Thread.sleep
      Returns:
      true/false

    • allowRetry

      public boolean allowRetry(Throwable exception)
      Description copied from interface: RetryPolicy
      Called when an operation has failed with a specific exception. This method should return true to make another attempt.
      Specified by:
      allowRetry in interface RetryPolicy
      Parameters:
      exception - the cause that this operation failed
      Returns:
      true/false