io.stallion.asyncTasks

Class DummyTaskPersister

java.lang.Object

io.stallion.dataAccess.BasePersister<T>

io.stallion.dataAccess.DummyPersister

io.stallion.asyncTasks.DummyTaskPersister

All Implemented Interfaces:

AsyncTaskPersister, Persister

public class DummyTaskPersister
extends DummyPersister
implements AsyncTaskPersister

Constructor Summary

Constructors

Constructor and Description
DummyTaskPersister()

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.

Methods inherited from class io.stallion.dataAccess.DummyPersister

attachWatcher, fetchAll, fetchOne, fetchOne, filterChain, hardDelete, onPreRead, persist, watchEventCallback

Methods inherited from class io.stallion.dataAccess.BasePersister

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.stallion.dataAccess.Persister

update

Constructor Detail

DummyTaskPersister

public DummyTaskPersister()

Method Detail

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