final class TaskServiceImpl extends java.lang.Object implements TaskService
Modifier and Type | Field and Description |
---|---|
private TaskDao |
dao |
private TaskExecutor |
executor |
private static org.slf4j.Logger |
log |
private javax.inject.Provider<Rescheduler> |
reschedulerProvider |
private javax.inject.Provider<TaskBuilder> |
taskBuilderProvider |
Constructor and Description |
---|
TaskServiceImpl(TaskExecutor executor,
javax.inject.Provider<Rescheduler> reschedulerProvider,
javax.inject.Provider<TaskBuilder> taskBuilderProvider,
TaskDao dao) |
Modifier and Type | Method and Description |
---|---|
private Task |
buildTask(EPJTask task,
javax.ws.rs.core.UriInfo uriInfo) |
Task |
getTask(org.bson.types.ObjectId taskId) |
java.util.List<Task> |
recoverAll(java.util.List<Task> tasks) |
Task |
schedule(EPJTask epjTask,
int delay,
java.util.concurrent.TimeUnit unit) |
private Task |
schedule(Task task,
int delay,
java.util.concurrent.TimeUnit unit) |
java.util.List<Task> |
selectRecoverableTasks(java.lang.String excludeTaskType) |
Task |
submit(EPJTask epjTask,
javax.ws.rs.core.UriInfo uriInfo) |
private static final org.slf4j.Logger log
private final javax.inject.Provider<TaskBuilder> taskBuilderProvider
private final TaskExecutor executor
private final TaskDao dao
private final javax.inject.Provider<Rescheduler> reschedulerProvider
@Inject public TaskServiceImpl(TaskExecutor executor, javax.inject.Provider<Rescheduler> reschedulerProvider, javax.inject.Provider<TaskBuilder> taskBuilderProvider, TaskDao dao)
public Task submit(EPJTask epjTask, javax.ws.rs.core.UriInfo uriInfo)
submit
in interface TaskService
public Task schedule(EPJTask epjTask, int delay, java.util.concurrent.TimeUnit unit)
schedule
in interface TaskService
public Task getTask(org.bson.types.ObjectId taskId)
getTask
in interface TaskService
public java.util.List<Task> selectRecoverableTasks(java.lang.String excludeTaskType)
selectRecoverableTasks
in interface TaskService
public java.util.List<Task> recoverAll(java.util.List<Task> tasks)
recoverAll
in interface TaskService