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
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods 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)
-
-
-
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 interfaceJobDelegate
-
isInterrupted
public boolean isInterrupted()
- Specified by:
isInterrupted
in interfaceJobDelegate
-
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 interfaceNotificationJobDelegate
-
execute
@Transactional public void execute(String executor) throws org.quartz.JobExecutionException
- Specified by:
execute
in interfaceNotificationJobDelegate
- Throws:
org.quartz.JobExecutionException
-
hasToBeRegistered
protected static boolean hasToBeRegistered(TaskExec<NotificationTask> execution)
-
handleRetries
protected void handleRetries(TaskExec<NotificationTask> execution)
-
-