com.enigmabridge.retry

Class EBRetry<Result,Error>

java.lang.Object

com.enigmabridge.retry.EBRetry<Result,Error>

All Implemented Interfaces:

EBCallback<Result,Error>

public class EBRetry<Result,Error>
extends Object
implements EBCallback<Result,Error>

Very simple base retry implementation. Ideally, new retry should be associated with the job. No reuse. Created by dusanklinec on 21.07.16.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EBRetry.WaitThread Simple notify me in thread.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	abort
protected int	attempts
protected boolean	cancel
protected static String	FIELD_STRATEGY_DATA
protected static String	FIELD_STRATEGY_TYPE
protected EBRetryJob<Result,Error>	job
protected EBRetryJobError<Error>	lastError
protected Result	lastResult
protected boolean	lastWasSuccess
protected List<EBRetryListener<Result,Error>>	listeners
protected EBRetryStrategy	retryStrategy
protected boolean	running
protected boolean	signalized
protected boolean	startedAsBlocking
protected long	waitingUntilMilli

Constructor Summary

Constructors

Constructor and Description
EBRetry()
EBRetry(EBRetryJob<Result,Error> job)
EBRetry(EBRetryStrategy retryStrategy)
EBRetry(EBRetryStrategy retryStrategy, EBRetryJob<Result,Error> job)
EBRetry(int maxAttempts, EBRetryJob<Result,Error> job)

Method Summary

Modifier and Type	Method and Description
void	addListener(EBRetryListener<Result,Error> listener)
void	fromJSON(org.json.JSONObject json)
int	getAttempts()
long	getWaitingUntilMilli()
boolean	isAborted()
boolean	isCancelled()
boolean	isRunning()
protected void	notifyListenerFailed(EBRetryJobError<Error> error)
protected void	notifyListenerSuccess(Result result)
void	onFail(EBRetryJobError<Error> error, boolean abort) Job calls this callback.
void	onSuccess(Result result) Job calls this callback.
void	onWaitFinished() Called in async run - when waiting was finished.
void	removeListener(EBRetryListener<Result,Error> listener)
void	reset()
EBFuture<Result,Error>	runAsync() Runs the job asynchronously.
EBFuture<Result,Error>	runAsync(EBRetryJob<Result,Error> job)
protected void	runAsyncInternal()
Result	runSync() Blocking version of the run.
void	setJob(EBRetryJob<Result,Error> job)
org.json.JSONObject	toJSON(org.json.JSONObject json)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

FIELD_STRATEGY_TYPE

protected static final String FIELD_STRATEGY_TYPE

See Also:

Constant Field Values

FIELD_STRATEGY_DATA

protected static final String FIELD_STRATEGY_DATA

See Also:

Constant Field Values

attempts

protected int attempts

retryStrategy

protected EBRetryStrategy retryStrategy

listeners

protected final List<EBRetryListener<Result,Error>> listeners

job

protected EBRetryJob<Result,Error> job

signalized

protected volatile boolean signalized

running

protected volatile boolean running

cancel

protected volatile boolean cancel

abort

protected volatile boolean abort

waitingUntilMilli

protected volatile long waitingUntilMilli

lastWasSuccess

protected boolean lastWasSuccess

startedAsBlocking

protected boolean startedAsBlocking

lastResult

protected Result lastResult

lastError

protected EBRetryJobError<Error> lastError

Constructor Detail

EBRetry

public EBRetry()

EBRetry

public EBRetry(EBRetryStrategy retryStrategy)

EBRetry

public EBRetry(int maxAttempts,
               EBRetryJob<Result,Error> job)

EBRetry

public EBRetry(EBRetryStrategy retryStrategy,
               EBRetryJob<Result,Error> job)

EBRetry

public EBRetry(EBRetryJob<Result,Error> job)

Method Detail

runAsync

public EBFuture<Result,Error> runAsync(EBRetryJob<Result,Error> job)

runAsync

public EBFuture<Result,Error> runAsync()

Runs the job asynchronously.

Returns:

future for manipulating async job

runAsyncInternal

protected void runAsyncInternal()

runSync

public Result runSync()
               throws EBRetryException

Blocking version of the run.

Returns:

Result of the sync operation

Throws:

EBRetryException - retry failed

onSuccess

public void onSuccess(Result result)

Job calls this callback.

Specified by:

onSuccess in interface EBCallback<Result,Error>

Parameters:

result - result of the job

onFail

public void onFail(EBRetryJobError<Error> error,
                   boolean abort)

Job calls this callback.

Specified by:

onFail in interface EBCallback<Result,Error>

Parameters:

error - error causing the job to fail

abort - if true abort the call.

onWaitFinished

public void onWaitFinished()

Called in async run - when waiting was finished.

getAttempts

public int getAttempts()

reset

public void reset()

addListener

public void addListener(EBRetryListener<Result,Error> listener)

removeListener

public void removeListener(EBRetryListener<Result,Error> listener)

setJob

public void setJob(EBRetryJob<Result,Error> job)

getWaitingUntilMilli

public long getWaitingUntilMilli()

isRunning

public boolean isRunning()

isCancelled

public boolean isCancelled()

isAborted

public boolean isAborted()

toJSON

public org.json.JSONObject toJSON(org.json.JSONObject json)

fromJSON

public void fromJSON(org.json.JSONObject json)

notifyListenerSuccess

protected void notifyListenerSuccess(Result result)

notifyListenerFailed

protected void notifyListenerFailed(EBRetryJobError<Error> error)