RetryingOperation (Data Pipeline JavaDoc)

java.lang.Object
- com.northconcepts.datapipeline.retry.RetryingOperation<T>

public class RetryingOperation<T>
extends Object

A proxy that attempts to re-run on failure.

Constructor Summary

Constructors
Constructor and Description

RetryingOperation()

Constructors
Constructor and Description
`RetryingOperation()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`T`	`call(Callable<T> callable)`
`long`	`getExceptionCount()` Returns the total number of exceptions/failures seen by this reader.
`Throwable`	`getFirstException()` Returns the first exception thrown for any individual read attempt.
`long`	`getInitialRetryDelay()` Returns the amount of time to wait (in milliseconds) after the first error, before retrying (default 1 second).
`Throwable`	`getLastException()` Returns the last exception thrown for any individual read attempt.
`long`	`getMaxErrorCount()` Returns the number of retries allowed across all read attempts (default max long - 1).
`int`	`getMaxRetryCount()` Returns the number of retries allowed for any individual read attempt (default 5).
`IRetryStrategy`	`getStrategy()` Returns the retry strategy (default `RetryStrategy.EXPONENTIAL_BACKOFF`).
`protected void`	`onFailure(Throwable exception)`
`void`	`run(Runnable runnable)`
`RetryingOperation<T>`	`setInitialRetryDelay(long initialRetryDelay)` Sets the amount of time to wait (in milliseconds) after the first error, before retrying (default 1 second).
`RetryingOperation<T>`	`setMaxErrorCount(long maxErrorCount)` Sets the number of retries allowed across all read attempts (default max long -1).
`RetryingOperation<T>`	`setMaxRetryCount(int maxRetryCount)` Sets the number of retries allowed for any individual read attempt (default 5).
`RetryingOperation<T>`	`setStrategy(IRetryStrategy strategy)` Sets the retry strategy (default `RetryStrategy.EXPONENTIAL_BACKOFF`).

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - RetryingOperation
```
public RetryingOperation()
```
- Method Detail
  - getMaxRetryCount
```
public int getMaxRetryCount()
```
    Returns the number of retries allowed for any individual read attempt (default 5).
  - setMaxRetryCount
```
public RetryingOperation<T> setMaxRetryCount(int maxRetryCount)
```
    Sets the number of retries allowed for any individual read attempt (default 5).
  - getMaxErrorCount
```
public long getMaxErrorCount()
```
    Returns the number of retries allowed across all read attempts (default max long - 1).
  - setMaxErrorCount
```
public RetryingOperation<T> setMaxErrorCount(long maxErrorCount)
```
    Sets the number of retries allowed across all read attempts (default max long -1).
  - getInitialRetryDelay
```
public long getInitialRetryDelay()
```
    Returns the amount of time to wait (in milliseconds) after the first error, before retrying (default 1 second).
  - setInitialRetryDelay
```
public RetryingOperation<T> setInitialRetryDelay(long initialRetryDelay)
```
    Sets the amount of time to wait (in milliseconds) after the first error, before retrying (default 1 second).
  - getStrategy
```
public IRetryStrategy getStrategy()
```
    Returns the retry strategy (default RetryStrategy.EXPONENTIAL_BACKOFF).
  - setStrategy
```
public RetryingOperation<T> setStrategy(IRetryStrategy strategy)
```
    Sets the retry strategy (default RetryStrategy.EXPONENTIAL_BACKOFF).
  - getExceptionCount
```
public long getExceptionCount()
```
    Returns the total number of exceptions/failures seen by this reader. This value is also the number of retries as long as maxErrorCount hasn't been exceeded.
  - getFirstException
```
public Throwable getFirstException()
```
    Returns the first exception thrown for any individual read attempt. This value will reset on the next read attempt after a successful retry.
  - getLastException
```
public Throwable getLastException()
```
    Returns the last exception thrown for any individual read attempt. This value will reset on the next read attempt after a successful retry.
  - run
```
public void run(Runnable runnable)
         throws Throwable
```
    Throws:
    
    Throwable
  - call
```
public T call(Callable<T> callable)
       throws Throwable
```
    Throws:
    
    Throwable
  - onFailure
```
protected void onFailure(Throwable exception)
                  throws Throwable
```
    Throws:
    
    Throwable

Class RetryingOperation<T>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

RetryingOperation

Method Detail

getMaxRetryCount

setMaxRetryCount

getMaxErrorCount

setMaxErrorCount

getInitialRetryDelay

setInitialRetryDelay

getStrategy

setStrategy

getExceptionCount

getFirstException

getLastException

run

call

onFailure