Class DefaultScheduleAndTriggerStrategy

java.lang.Object
de.hybris.platform.task.impl.DefaultScheduleAndTriggerStrategy
All Implemented Interfaces:
ScheduleAndTriggerStrategy

public class DefaultScheduleAndTriggerStrategy extends Object implements ScheduleAndTriggerStrategy
  • Constructor Details

    • DefaultScheduleAndTriggerStrategy

      public DefaultScheduleAndTriggerStrategy()
  • Method Details

    • 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