io.stallion.asyncTasks

Interface AsyncTaskPersister

All Known Implementing Classes:

AsyncTaskDbPersister, AsyncTaskFilePersister, DummyTaskPersister

public interface AsyncTaskPersister

Method Summary

Modifier and Type	Method and Description
void	deleteOldTasks() Delete all tasks from the database that were completed more than 40 days ago
boolean	lockForProcessing(AsyncTask task) Lock the task in the datastore.
boolean	markComplete(AsyncTask task) Mark the task as completed.
boolean	markFailed(AsyncTask task, Throwable e) Mark the last task execution as failed in the datastore.

Method Detail

markFailed

boolean markFailed(AsyncTask task,
                   Throwable e)

Mark the last task execution as failed in the datastore. Remove locks and increment the try count. Mark for retry with exponential back-off. If the count is too high, do not mark for retry.

Parameters:

task -

e -

Returns:

markComplete

boolean markComplete(AsyncTask task)

Mark the task as completed.

Parameters:

task -

Returns:

lockForProcessing

boolean lockForProcessing(AsyncTask task)

Lock the task in the datastore. Should update the database atomically to prevent the same task being locked by different stallion instances.

Parameters:

task -

Returns:

deleteOldTasks

void deleteOldTasks()

Delete all tasks from the database that were completed more than 40 days ago