001/* 002 * Stallion Core: A Modern Web Framework 003 * 004 * Copyright (C) 2015 - 2016 Stallion Software LLC. 005 * 006 * This program is free software: you can redistribute it and/or modify it under the terms of the 007 * GNU General Public License as published by the Free Software Foundation, either version 2 of 008 * the License, or (at your option) any later version. This program is distributed in the hope that 009 * it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of 010 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public 011 * License for more details. You should have received a copy of the GNU General Public License 012 * along with this program. If not, see <http://www.gnu.org/licenses/gpl-2.0.html>. 013 * 014 * 015 * 016 */ 017 018package io.stallion.asyncTasks; 019 020import static io.stallion.utils.Literals.*; 021 022 023public interface AsyncTaskPersister { 024 025 /** 026 * Mark the last task execution as failed in the datastore. 027 * Remove locks and increment the try count. Mark for retry with exponential back-off. 028 * If the count is too high, do not mark for retry. 029 * @param task 030 * @param e 031 * @return 032 */ 033 public boolean markFailed(AsyncTask task, Throwable e); 034 035 /** 036 * Mark the task as completed. 037 * @param task 038 * @return 039 */ 040 public boolean markComplete(AsyncTask task); 041 042 /** 043 * Lock the task in the datastore. Should update the database atomically to prevent 044 * the same task being locked by different stallion instances. 045 * @param task 046 * @return 047 */ 048 public boolean lockForProcessing(AsyncTask task); 049 050 /** 051 * Delete all tasks from the database that were completed more than 40 days ago 052 */ 053 public void deleteOldTasks(); 054 055}