io.stallion.asyncTasks

Class AsyncTaskDbPersister

java.lang.Object

io.stallion.dataAccess.BasePersister<T>

io.stallion.dataAccess.db.DbPersister<AsyncTask>

io.stallion.asyncTasks.AsyncTaskDbPersister

All Implemented Interfaces:

AsyncTaskPersister, Persister<AsyncTask>

public class AsyncTaskDbPersister
extends DbPersister<AsyncTask>
implements AsyncTaskPersister

Constructor Summary

Constructors

Constructor and Description
AsyncTaskDbPersister()

Method Summary

Modifier and Type	Method and Description
void	deleteOldTasks() Delete all tasks from the database that were completed more than 40 days ago
AsyncTask	findAndLockNextTask(Long now)
AsyncTask	findAndLockNextTask(Long now, int depth)
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.

Methods inherited from class io.stallion.dataAccess.db.DbPersister

attachWatcher, checkNeedsSync, fetchAll, fetchOne, fetchOne, filterChain, getBucketSyncedKey, getTableName, hardDelete, init, isDbBacked, onPreRead, persist, syncFromDatabase, update, watchEventCallback

Methods inherited from class io.stallion.dataAccess.BasePersister

getBucket, getItemController, getModelClass, getStash, handleFetchOne, onFetchOne, reloadIfNewer, setBucket, setItemController, setModelClass, setStash

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncTaskDbPersister

public AsyncTaskDbPersister()

Method Detail

findAndLockNextTask

public AsyncTask findAndLockNextTask(Long now)

findAndLockNextTask

public AsyncTask findAndLockNextTask(Long now,
                                     int depth)

markFailed

public boolean markFailed(AsyncTask task,
                          Throwable e)

Description copied from interface: AsyncTaskPersister

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.

Specified by:

markFailed in interface AsyncTaskPersister

Returns:

markComplete

public boolean markComplete(AsyncTask task)

Description copied from interface: AsyncTaskPersister

Mark the task as completed.

Specified by:

markComplete in interface AsyncTaskPersister

Returns:

lockForProcessing

public boolean lockForProcessing(AsyncTask task)

Description copied from interface: AsyncTaskPersister

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

Specified by:

lockForProcessing in interface AsyncTaskPersister

Returns:

deleteOldTasks

public void deleteOldTasks()

Description copied from interface: AsyncTaskPersister

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

Specified by:

deleteOldTasks in interface AsyncTaskPersister