Package org.apache.syncope.core.provisioning.java.job.notification

Class AbstractNotificationJobDelegate

java.lang.Object

org.apache.syncope.core.provisioning.java.job.notification.AbstractNotificationJobDelegate

All Implemented Interfaces:

JobDelegate, NotificationJobDelegate

Direct Known Subclasses:

MailNotificationJobDelegate

public abstract class AbstractNotificationJobDelegate
extends Object
implements NotificationJobDelegate

Field Summary

Fields

Modifier and Type	Field	Description
protected AuditManager	auditManager
protected boolean	interrupt
protected boolean	interrupted
protected static Logger	LOG
protected NotificationManager	notificationManager
protected ApplicationEventPublisher	publisher
protected TaskDAO	taskDAO
protected TaskUtilsFactory	taskUtilsFactory

Fields inherited from interface org.apache.syncope.core.provisioning.api.job.JobDelegate

OPERATION_ID

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractNotificationJobDelegate(TaskDAO taskDAO, TaskUtilsFactory taskUtilsFactory, AuditManager auditManager, NotificationManager notificationManager, ApplicationEventPublisher publisher)

Method Summary

Modifier and Type	Method	Description
void	execute(String executor)
TaskExec<NotificationTask>	executeSingle(NotificationTask task, String executor)
protected void	handleRetries(TaskExec<NotificationTask> execution)
protected static boolean	hasToBeRegistered(TaskExec<NotificationTask> execution)
void	interrupt()
boolean	isInterrupted()
protected abstract void	notify(String to, NotificationTask task, TaskExec<NotificationTask> execution)
protected void	setStatus(String status)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

taskDAO

protected final TaskDAO taskDAO

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

auditManager

protected final AuditManager auditManager

notificationManager

protected final NotificationManager notificationManager

publisher

protected final ApplicationEventPublisher publisher

interrupt

protected boolean interrupt

interrupted

protected boolean interrupted

Constructor Detail

AbstractNotificationJobDelegate

protected AbstractNotificationJobDelegate(TaskDAO taskDAO,
                                          TaskUtilsFactory taskUtilsFactory,
                                          AuditManager auditManager,
                                          NotificationManager notificationManager,
                                          ApplicationEventPublisher publisher)

Method Detail

setStatus

protected void setStatus(String status)

interrupt

public void interrupt()

Specified by:

interrupt in interface JobDelegate

isInterrupted

public boolean isInterrupted()

Specified by:

isInterrupted in interface JobDelegate

notify

protected abstract void notify(String to,
                               NotificationTask task,
                               TaskExec<NotificationTask> execution)
                        throws Exception

Throws:

Exception

executeSingle

@Transactional
public TaskExec<NotificationTask> executeSingle(NotificationTask task,
                                                String executor)

Specified by:

executeSingle in interface NotificationJobDelegate

execute

@Transactional
public void execute(String executor)
             throws org.quartz.JobExecutionException

Specified by:

execute in interface NotificationJobDelegate

Throws:

org.quartz.JobExecutionException

hasToBeRegistered

protected static boolean hasToBeRegistered(TaskExec<NotificationTask> execution)

handleRetries

protected void handleRetries(TaskExec<NotificationTask> execution)