de.hybris.platform.task.impl

Class DefaultScheduleAndTriggerStrategy

java.lang.Object

de.hybris.platform.task.impl.DefaultScheduleAndTriggerStrategy

All Implemented Interfaces:

ScheduleAndTriggerStrategy

public class DefaultScheduleAndTriggerStrategy
extends Object
implements ScheduleAndTriggerStrategy

Constructor Summary

Constructors

Constructor and Description
DefaultScheduleAndTriggerStrategy()

Method Summary

Modifier and Type	Method and Description
protected void	disableNestedTransactions(SessionContext loclCtx)
protected void	doScheduleInTransaction(TaskModel task)
protected void	finishScheduleTaskWithConditions(TaskModel task, Date scheduledExecutionDate)
protected boolean	insertEventConditionOrRetryMatch(TaskEvent event) Returns true if repolling tasks makes sense
protected void	insertScheduleConditionOrRetryMatch(TaskModel task, PK taskPK, TaskConditionModel cond)
protected boolean	isIgnorableScheduleConditionException(TaskConditionModel condition, Exception e)
protected void	prepareScheduleTaskWithConditions(TaskModel task)
protected boolean	retryMatchConditionForEvent(TaskEvent event)
protected void	retryMatchConditionForSchedule(TaskConditionModel cond, PK taskPK, ModelSavingException creationExcpetion)
void	scheduleTask(TaskModel task) Schedules a new task.
protected void	scheduleTaskInternal(TaskModel task)
protected void	scheduleTaskWithConditions(TaskModel task)
protected void	scheduleTaskWithoutConditions(TaskModel task)
void	setModelService(ModelService modelService)
void	setTaskDao(TaskDAO dao)
void	setTaskDAO(TaskDAO dao)
boolean	triggerEvent(String uniqueId) Triggers a task event.
boolean	triggerEvent(String uniqueId, Date expirationDate) Triggers a task event.
boolean	triggerEvent(TaskEvent event) Triggers a task event.
protected boolean	triggerEventInTransaction(TaskEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultScheduleAndTriggerStrategy

public DefaultScheduleAndTriggerStrategy()

Method Detail

triggerEvent

public boolean triggerEvent(TaskEvent event)

Description copied from interface: ScheduleAndTriggerStrategy

Triggers a task event.

Specified by:

triggerEvent in interface ScheduleAndTriggerStrategy

Parameters:

event - event to be triggered

Returns:

true if operation succeeded or false if event has been already triggered

triggerEventInTransaction

protected boolean triggerEventInTransaction(TaskEvent event)

insertEventConditionOrRetryMatch

protected boolean insertEventConditionOrRetryMatch(TaskEvent event)

Returns true if repolling tasks makes sense

retryMatchConditionForEvent

protected boolean retryMatchConditionForEvent(TaskEvent event)

isIgnorableScheduleConditionException

protected boolean isIgnorableScheduleConditionException(TaskConditionModel condition,
                                                        Exception e)

triggerEvent

public boolean triggerEvent(String uniqueId)

Description copied from interface: ScheduleAndTriggerStrategy

Triggers a task event.

Specified by:

triggerEvent in interface ScheduleAndTriggerStrategy

Returns:

true if re-polling on this node is advisable based on the result of the trigger operation

triggerEvent

public boolean triggerEvent(String uniqueId,
                            Date expirationDate)

Description copied from interface: ScheduleAndTriggerStrategy

Triggers a task event.

Specified by:

triggerEvent in interface ScheduleAndTriggerStrategy

Parameters:

uniqueId - id of event

expirationDate - expiration date for event

scheduleTask

public void scheduleTask(TaskModel task)

Description copied from interface: ScheduleAndTriggerStrategy

Schedules a new task.

Specified by:

scheduleTask in interface ScheduleAndTriggerStrategy

scheduleTaskInternal

protected void scheduleTaskInternal(TaskModel task)

doScheduleInTransaction

protected void doScheduleInTransaction(TaskModel task)

scheduleTaskWithoutConditions

protected void scheduleTaskWithoutConditions(TaskModel task)

scheduleTaskWithConditions

protected void scheduleTaskWithConditions(TaskModel task)

finishScheduleTaskWithConditions

protected void finishScheduleTaskWithConditions(TaskModel task,
                                                Date scheduledExecutionDate)

prepareScheduleTaskWithConditions

protected void prepareScheduleTaskWithConditions(TaskModel task)

insertScheduleConditionOrRetryMatch

protected void insertScheduleConditionOrRetryMatch(TaskModel task,
                                                   PK taskPK,
                                                   TaskConditionModel cond)

retryMatchConditionForSchedule

protected void retryMatchConditionForSchedule(TaskConditionModel cond,
                                              PK taskPK,
                                              ModelSavingException creationExcpetion)

disableNestedTransactions

protected void disableNestedTransactions(SessionContext loclCtx)

setModelService

public void setModelService(ModelService modelService)

setTaskDao

public void setTaskDao(TaskDAO dao)

Specified by:

setTaskDao in interface ScheduleAndTriggerStrategy

setTaskDAO

public void setTaskDAO(TaskDAO dao)

Specified by:

setTaskDAO in interface ScheduleAndTriggerStrategy