io.stallion.asyncTasks

Class AsyncTaskFilePersister

java.lang.Object

io.stallion.dataAccess.BasePersister<T>

io.stallion.dataAccess.file.FilePersisterBase<T>

io.stallion.dataAccess.file.JsonFilePersister

io.stallion.asyncTasks.AsyncTaskFilePersister

All Implemented Interfaces:

AsyncTaskPersister, Persister

public class AsyncTaskFilePersister
extends JsonFilePersister
implements AsyncTaskPersister

Field Summary

Fields inherited from class io.stallion.dataAccess.file.FilePersisterBase

sortDirection, sortField

Constructor Summary

Constructors

Constructor and Description
AsyncTaskFilePersister()

Method Summary

Modifier and Type	Method and Description
void	attachWatcher() The watcher for JsonTaskPersister only watches the manual entry folder.
void	deleteOldTasks() Delete all tasks from the database that were completed more than 40 days ago
List	fetchAll() Fetch all the items from the underlying data store.
String	fullFilePathForObj(Model model)
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.
String	relativeFilePathForObj(Model model)
void	watchEventCallback(String relativePath) This callback occurs when the watcher finds a new file added to manual retry We load the task, delete the original file, then re-enqueue the task

Methods inherited from class io.stallion.dataAccess.file.JsonFilePersister

doFetchOne, getFileExtensions, persist

Methods inherited from class io.stallion.dataAccess.file.FilePersisterBase

fetchOne, fetchOne, fetchOne, filterChain, fullFilePathForId, getBucketFolderPath, getFileToIdMap, getIdToFileMap, getItemArrayName, hardDelete, init, isManyItemsPerFile, makeIdFromFilePath, makePathForObject, matchesExtension, onPostLoadFromFile, reloadIfNewer, setBucketFolderPath, setFileToIdMap, setIdToFileMap, setItemArrayName, setManyItemsPerFile

Methods inherited from class io.stallion.dataAccess.BasePersister

getBucket, getItemController, getModelClass, getStash, handleFetchOne, isDbBacked, onFetchOne, onPreRead, 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

AsyncTaskFilePersister

public AsyncTaskFilePersister()

Method Detail

fetchAll

public List fetchAll()

Description copied from interface: Persister

Fetch all the items from the underlying data store.

Specified by:

fetchAll in interface Persister

Overrides:

fetchAll in class FilePersisterBase

Returns:

watchEventCallback

public void watchEventCallback(String relativePath)

This callback occurs when the watcher finds a new file added to manual retry We load the task, delete the original file, then re-enqueue the task

Specified by:

watchEventCallback in interface Persister

Overrides:

watchEventCallback in class FilePersisterBase

Parameters:

relativePath -

attachWatcher

public void attachWatcher()

The watcher for JsonTaskPersister only watches the manual entry folder. If a task fails too many times, then we fix the problem, we need a way to force the failed tasks to be retried. The way to do this is to manually edit the JSON, then move the file into the manualRetry folder. The watcher will pick it up, and move it into the pending queue

Specified by:

attachWatcher in interface Persister

Overrides:

attachWatcher in class FilePersisterBase

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:

markComplete

public boolean markComplete(AsyncTask task)

Description copied from interface: AsyncTaskPersister

Mark the task as completed.

Specified by:

markComplete in interface AsyncTaskPersister

Returns:

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:

fullFilePathForObj

public String fullFilePathForObj(Model model)

Overrides:

fullFilePathForObj in class FilePersisterBase

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

relativeFilePathForObj

public String relativeFilePathForObj(Model model)

Overrides:

relativeFilePathForObj in class FilePersisterBase