class RetrySender MAX_BACKOFF_DURATION = 10 STATUS_OK = '200' def initialize(max_retries, inner, sleeper, logger) @max_retries = max_retries @inner = inner @sleeper = sleeper @logger = logger end def send(request) response = @inner.send(request) (0..@max_retries-1).each { |i| if response.status_code == STATUS_OK break end backoff(i) response = @inner.send(request) } response end def backoff(attempt) backoff_duration = [attempt, MAX_BACKOFF_DURATION].min @logger.log("There was an error processing the request. Retrying in #{backoff_duration} seconds...") @sleeper.sleep(backoff_duration) end end