org.apache.syncope.core.logic

Class TaskLogic

java.lang.Object

org.apache.syncope.core.logic.AbstractExecutableLogic<TaskTO>

org.apache.syncope.core.logic.TaskLogic

@Component
public class TaskLogic
extends AbstractExecutableLogic<TaskTO>

Field Summary

Fields

Modifier and Type	Field and Description
protected JobManager	jobManager
protected JobStatusDAO	jobStatusDAO
protected static org.slf4j.Logger	LOG
protected SchedulerFactoryBean	scheduler

Constructor Summary

Constructors

Constructor and Description
TaskLogic()

Method Summary

Modifier and Type	Method and Description
void	actionJob(String key, JobAction action)
<T extends SchedTaskTO> T	createSchedTask(TaskType type, T taskTO)
<T extends TaskTO> T	delete(TaskType type, String key)
ExecTO	deleteExecution(String execKey)
List<BatchResponseItem>	deleteExecutions(String key, Date before, Date after)
protected void	doActionJob(org.quartz.JobKey jobKey, JobAction action)
protected List<JobTO>	doListJobs(boolean includeCustom)
ExecTO	execute(String key, Date startAt, boolean dryRun)
JobTO	getJob(String key)
protected JobTO	getJobTO(org.quartz.JobKey jobKey, boolean includeCustom)
protected Triple<JobType,String,String>	getReference(org.quartz.JobKey jobKey)
Pair<Integer,List<ExecTO>>	listExecutions(String key, Date before, Date after, int page, int size, List<OrderByClause> orderByClauses)
List<JobTO>	listJobs()
List<ExecTO>	listRecentExecutions(int max)
List<PropagationTaskTO>	purgePropagations(Date since, List<ExecStatus> statuses, List<String> resources)
<T extends TaskTO> T	read(TaskType type, String key, boolean details)
T	resolveBeanReference(Method method, Object... args) Resolves stored bean (if existing) referred by the given CUD method.
protected TaskTO	resolveReference(Method method, Object... args)
<T extends TaskTO> Pair<Integer,List<T>>	search(TaskType type, String resource, String notification, AnyTypeKind anyTypeKind, String entityKey, int page, int size, List<OrderByClause> orderByClauses, boolean details)
<T extends SchedTaskTO> T	updateSchedTask(TaskType type, SchedTaskTO taskTO)

Methods inherited from class java.lang.Object

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

Field Detail

jobManager

@Autowired
protected JobManager jobManager

scheduler

@Autowired
protected SchedulerFactoryBean scheduler

jobStatusDAO

@Autowired
protected JobStatusDAO jobStatusDAO

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

TaskLogic

public TaskLogic()

Method Detail

createSchedTask

@PreAuthorize(value="hasRole(\'TASK_CREATE\')")
public <T extends SchedTaskTO> T createSchedTask(TaskType type,
                                                                                                 T taskTO)

updateSchedTask

@PreAuthorize(value="hasRole(\'TASK_UPDATE\')")
public <T extends SchedTaskTO> T updateSchedTask(TaskType type,
                                                                                                 SchedTaskTO taskTO)

search

@PreAuthorize(value="hasRole(\'TASK_LIST\')")
 @Transactional(readOnly=true)
public <T extends TaskTO> Pair<Integer,List<T>> search(TaskType type,
                                                                                                                                    String resource,
                                                                                                                                    String notification,
                                                                                                                                    AnyTypeKind anyTypeKind,
                                                                                                                                    String entityKey,
                                                                                                                                    int page,
                                                                                                                                    int size,
                                                                                                                                    List<OrderByClause> orderByClauses,
                                                                                                                                    boolean details)

read

@PreAuthorize(value="hasRole(\'TASK_READ\')")
 @Transactional(readOnly=true)
public <T extends TaskTO> T read(TaskType type,
                                                                                                              String key,
                                                                                                              boolean details)

execute

@PreAuthorize(value="hasRole(\'TASK_EXECUTE\')")
public ExecTO execute(String key,
                                                                       Date startAt,
                                                                       boolean dryRun)

Specified by:

execute in class AbstractExecutableLogic<TaskTO>

delete

@PreAuthorize(value="hasRole(\'TASK_DELETE\')")
public <T extends TaskTO> T delete(TaskType type,
                                                                                   String key)

listExecutions

@PreAuthorize(value="hasRole(\'TASK_READ\')")
public Pair<Integer,List<ExecTO>> listExecutions(String key,
                                                                                               Date before,
                                                                                               Date after,
                                                                                               int page,
                                                                                               int size,
                                                                                               List<OrderByClause> orderByClauses)

Specified by:

listExecutions in class AbstractExecutableLogic<TaskTO>

listRecentExecutions

@PreAuthorize(value="hasRole(\'TASK_LIST\')")
public List<ExecTO> listRecentExecutions(int max)

Specified by:

listRecentExecutions in class AbstractExecutableLogic<TaskTO>

deleteExecution

@PreAuthorize(value="hasRole(\'TASK_DELETE\')")
public ExecTO deleteExecution(String execKey)

Specified by:

deleteExecution in class AbstractExecutableLogic<TaskTO>

deleteExecutions

@PreAuthorize(value="hasRole(\'TASK_DELETE\')")
public List<BatchResponseItem> deleteExecutions(String key,
                                                                                                Date before,
                                                                                                Date after)

Specified by:

deleteExecutions in class AbstractExecutableLogic<TaskTO>

getReference

protected Triple<JobType,String,String> getReference(org.quartz.JobKey jobKey)

listJobs

@PreAuthorize(value="hasRole(\'TASK_LIST\')")
public List<JobTO> listJobs()

Specified by:

listJobs in class AbstractExecutableLogic<TaskTO>

getJob

@PreAuthorize(value="hasRole(\'TASK_READ\')")
public JobTO getJob(String key)

Specified by:

getJob in class AbstractExecutableLogic<TaskTO>

actionJob

@PreAuthorize(value="hasRole(\'TASK_EXECUTE\')")
public void actionJob(String key,
                                                                       JobAction action)

Specified by:

actionJob in class AbstractExecutableLogic<TaskTO>

purgePropagations

@PreAuthorize(value="hasRole(\'TASK_DELETE\')")
public List<PropagationTaskTO> purgePropagations(Date since,
                                                                                                 List<ExecStatus> statuses,
                                                                                                 List<String> resources)

resolveReference

protected TaskTO resolveReference(Method method,
                                  Object... args)
                           throws UnresolvedReferenceException

Throws:

UnresolvedReferenceException

getJobTO

protected JobTO getJobTO(org.quartz.JobKey jobKey,
                         boolean includeCustom)
                  throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

doListJobs

protected List<JobTO> doListJobs(boolean includeCustom)

doActionJob

protected void doActionJob(org.quartz.JobKey jobKey,
                           JobAction action)

resolveBeanReference

public T resolveBeanReference(Method method,
                              Object... args)
                       throws UnresolvedReferenceException

Resolves stored bean (if existing) referred by the given CUD method. Read-only methods will be unresolved for performance reasons.

Parameters:

method - method.

args - method arguments.

Returns:

referred stored bean.

Throws:

UnresolvedReferenceException - in case of failures, read-only methods and unresolved bean.