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

Class DefaultNotificationManager

java.lang.Object

org.apache.syncope.core.provisioning.java.notification.DefaultNotificationManager

All Implemented Interfaces:

NotificationManager

@Transactional(rollbackFor=java.lang.Throwable.class)
public class DefaultNotificationManager
extends Object
implements NotificationManager

Field Summary

Fields

Modifier and Type	Field	Description
protected final AnyMatchDAO	anyMatchDAO
protected final AnyObjectDAO	anyObjectDAO
protected final AnyObjectDataBinder	anyObjectDataBinder
protected final AnySearchDAO	anySearchDAO
protected final ConfParamOps	confParamOps
protected final DerAttrHandler	derAttrHandler
protected final DerSchemaDAO	derSchemaDAO
protected final EntityFactory	entityFactory
protected final GroupDAO	groupDAO
protected final GroupDataBinder	groupDataBinder
protected final IntAttrNameParser	intAttrNameParser
protected static final Logger	LOG
protected final NotificationDAO	notificationDAO
protected Optional<RecipientsProvider>	perContextRecipientsProvider
protected final SearchCondVisitor	searchCondVisitor
protected final TaskDAO	taskDAO
protected final UserDAO	userDAO
protected final UserDataBinder	userDataBinder
protected final VirAttrHandler	virAttrHandler
protected final VirSchemaDAO	virSchemaDAO

Constructor Summary

Constructors

Constructor

Description

DefaultNotificationManager(DerSchemaDAO derSchemaDAO, VirSchemaDAO virSchemaDAO, NotificationDAO notificationDAO, AnyObjectDAO anyObjectDAO, UserDAO userDAO, GroupDAO groupDAO, AnySearchDAO anySearchDAO, AnyMatchDAO anyMatchDAO, TaskDAO taskDAO, DerAttrHandler derAttrHandler, VirAttrHandler virAttrHandler, UserDataBinder userDataBinder, GroupDataBinder groupDataBinder, AnyObjectDataBinder anyObjectDataBinder, ConfParamOps confParamOps, EntityFactory entityFactory, IntAttrNameParser intAttrNameParser, SearchCondVisitor searchCondVisitor)

Method Summary

Modifier and Type	Method	Description
long	countExecutionsWithStatus(String taskKey, String status)	Count the number of task executions of a given task with a given status.
List<NotificationTask>	createTasks(String who, OpEvent.CategoryType type, String category, String subcategory, String op, OpEvent.Outcome outcome, Object before, Object output, Object... input)	Create notification tasks for each notification matching provided conditions.
void	createTasks(AfterHandlingEvent event)	Create notification tasks according to the provided event.
long	getMaxRetries()
protected NotificationTask	getNotificationTask(Notification notification, Any<?> any, Map<String,Object> jexlVars)	Create a notification task.
protected String	getRecipientEmail(String recipientAttrName, User user)
boolean	notificationsAvailable(String domain, OpEvent.CategoryType type, String category, String subcategory, String op)	Checks if notifications are available matching the provided conditions.
void	setTaskExecuted(String taskKey, boolean executed)	Set execution state of NotificationTask with provided id.
TaskExec<NotificationTask>	storeExec(TaskExec<NotificationTask> execution)	Store execution of a NotificationTask.

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final Logger LOG

derSchemaDAO

protected final DerSchemaDAO derSchemaDAO

virSchemaDAO

protected final VirSchemaDAO virSchemaDAO

notificationDAO

protected final NotificationDAO notificationDAO

anyObjectDAO

protected final AnyObjectDAO anyObjectDAO

userDAO

protected final UserDAO userDAO

groupDAO

protected final GroupDAO groupDAO

anySearchDAO

protected final AnySearchDAO anySearchDAO

anyMatchDAO

protected final AnyMatchDAO anyMatchDAO

taskDAO

protected final TaskDAO taskDAO

derAttrHandler

protected final DerAttrHandler derAttrHandler

virAttrHandler

protected final VirAttrHandler virAttrHandler

userDataBinder

protected final UserDataBinder userDataBinder

groupDataBinder

protected final GroupDataBinder groupDataBinder

anyObjectDataBinder

protected final AnyObjectDataBinder anyObjectDataBinder

confParamOps

protected final ConfParamOps confParamOps

entityFactory

protected final EntityFactory entityFactory

intAttrNameParser

protected final IntAttrNameParser intAttrNameParser

searchCondVisitor

protected final SearchCondVisitor searchCondVisitor

perContextRecipientsProvider

protected Optional<RecipientsProvider> perContextRecipientsProvider

Constructor Details

DefaultNotificationManager

public DefaultNotificationManager(DerSchemaDAO derSchemaDAO,
 VirSchemaDAO virSchemaDAO,
 NotificationDAO notificationDAO,
 AnyObjectDAO anyObjectDAO,
 UserDAO userDAO,
 GroupDAO groupDAO,
 AnySearchDAO anySearchDAO,
 AnyMatchDAO anyMatchDAO,
 TaskDAO taskDAO,
 DerAttrHandler derAttrHandler,
 VirAttrHandler virAttrHandler,
 UserDataBinder userDataBinder,
 GroupDataBinder groupDataBinder,
 AnyObjectDataBinder anyObjectDataBinder,
 ConfParamOps confParamOps,
 EntityFactory entityFactory,
 IntAttrNameParser intAttrNameParser,
 SearchCondVisitor searchCondVisitor)

Method Details

getMaxRetries

@Transactional(readOnly=true)
public long getMaxRetries()

Specified by:

getMaxRetries in interface NotificationManager

getNotificationTask

protected NotificationTask getNotificationTask(Notification notification,
 Any<?> any,
 Map<String,Object> jexlVars)

Create a notification task.

Parameters:

notification - notification to take as model

any - the any object this task is about

jexlVars - JEXL variables

Returns:

notification task, fully populated

notificationsAvailable

public boolean notificationsAvailable(String domain,
 OpEvent.CategoryType type,
 String category,
 String subcategory,
 String op)

Description copied from interface: NotificationManager

Checks if notifications are available matching the provided conditions.

Specified by:

notificationsAvailable in interface NotificationManager

Parameters:

domain - domain

type - event category type

category - event category

subcategory - event subcategory

op - operation

Returns:

created notification tasks

createTasks

public void createTasks(AfterHandlingEvent event)

Description copied from interface: NotificationManager

Create notification tasks according to the provided event.

Specified by:

createTasks in interface NotificationManager

Parameters:

event - Spring event raised during Logic processing

createTasks

public List<NotificationTask> createTasks(String who,
 OpEvent.CategoryType type,
 String category,
 String subcategory,
 String op,
 OpEvent.Outcome outcome,
 Object before,
 Object output,
 Object... input)

Description copied from interface: NotificationManager

Create notification tasks for each notification matching provided conditions.

Specified by:

createTasks in interface NotificationManager

Parameters:

who - user triggering the event

type - event category type

category - event category

subcategory - event subcategory

op - operation

outcome - result value condition.

before - object(s) availabile before the event

output - object(s) produced by the event

input - object(s) provided to the event

Returns:

created notification tasks

getRecipientEmail

protected String getRecipientEmail(String recipientAttrName,
 User user)

storeExec

public TaskExec<NotificationTask> storeExec(TaskExec<NotificationTask> execution)

Description copied from interface: NotificationManager

Store execution of a NotificationTask.

Specified by:

storeExec in interface NotificationManager

Parameters:

execution - task execution.

Returns:

merged task execution.

setTaskExecuted

public void setTaskExecuted(String taskKey,
 boolean executed)

Description copied from interface: NotificationManager

Set execution state of NotificationTask with provided id.

Specified by:

setTaskExecuted in interface NotificationManager

Parameters:

taskKey - task to be updated

executed - execution state

countExecutionsWithStatus

public long countExecutionsWithStatus(String taskKey,
 String status)

Description copied from interface: NotificationManager

Count the number of task executions of a given task with a given status.

Specified by:

countExecutionsWithStatus in interface NotificationManager

Parameters:

taskKey - task

status - status

Returns:

number of task executions