de.hybris.platform.task.impl

Class DefaultTaskService

java.lang.Object

de.hybris.platform.task.impl.DefaultTaskService

All Implemented Interfaces:

TaskService

public class DefaultTaskService
extends Object
implements TaskService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultTaskService.PoolingQueueSizeGauge

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_POLLING_INTERVAL
static int	DEFAULT_SHUTDOWN_WAIT
static int	DEFAULT_WORKER_MAX
static String	POOLING_QUEUE_SIZE_METRIC
static String	POOLING_TIME_METRIC
static String	PROCESSING_HITS_METRIC
static String	PROCESSING_MISSES_METRIC
static String	PROCESSING_TIME_METRIC
static String	QUEUE_SIZE_METRIC

Fields inherited from interface de.hybris.platform.task.TaskService

BEAN_ID

Constructor Summary

Constructors

Constructor and Description
DefaultTaskService()

Method Summary

Modifier and Type	Method and Description
protected boolean	checkSystemOK()
protected void	checkTask(TaskModel toBeScheduled)
protected void	checkTaskConditions(TaskModel toBeScheduled, TaskConditionModel cond)
void	destroy() Shut down this component
TaskEngine	getEngine()
protected TaskExecutionStrategy	getExecutionStrategy(TaskRunner<? extends TaskModel> runner)
protected DefaultTaskService.PoolingQueueSizeGauge	getPoolingQueueSizeGauge()
protected TaskRunner	getRunner(String runnerBean)
protected TaskRunner	getRunner(Task task)
protected TaskDAO	getTaskDao()
protected Tenant	getTenant()
void	init() Starts up this component
protected boolean	isAllowedToStart()
protected boolean	isAllowedToStart(int clusterId)
boolean	isRunning()
protected void	markTaskFailed(Task task)
protected void	poll()
protected void	process(de.hybris.platform.task.impl.DefaultTaskService.VersionPK versionPK)
protected void	processCondition(TaskCondition cond)
protected void	processInTenant(de.hybris.platform.task.impl.DefaultTaskService.VersionPK versionPK)
protected void	processTask(Task task, de.hybris.platform.task.impl.DefaultTaskService.VersionPK versionPK)
protected Set<Integer>	readExcludedNodesFromConfig()
protected int	readMaxWorkersFromConfig()
protected int	readPollingIntervalFromConfig()
protected int	readShutdownWaitFromConfig()
protected int	readWorkersIdleFromConfig()
void	repoll(Integer nodeId, String nodeGroupId)
protected void	scheduleRetry(Task task, Date nextExecution, int turn)
protected boolean	scheduleRetryIfAllowed(Task task, RetryLaterException e)
void	scheduleTask(TaskModel task) Schedule a task.
void	setEventService(EventService eventService)
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setMetricRegistry(MetricRegistry metricRegistry)
void	setModelService(ModelService modelService)
void	setScheduleAndTriggerStrategy(ScheduleAndTriggerStrategy scheduleAndTriggerStrategy)
void	setTaskDao(TaskDAO dao)
void	setTaskExecutionStrategies(Collection<? extends TaskExecutionStrategy> taskExecutionStrategies)
void	setTypeService(TypeService typeService)
List<de.hybris.platform.task.impl.DefaultTaskService.VersionPK>	toVersionPKsList(List<List<Long>> records)
void	triggerEvent(String uniqueId) Trigger an event on task module.
void	triggerEvent(String uniqueId, Date expirationDate) Trigger an event on task module.
boolean	triggerEvent(TaskEvent event) Trigger event on task module.
void	triggerRepoll(Integer nodeId, String nodeGroupId) Triggers re-poll at the specified cluster node.
protected void	triggerRepollAfterSchedule(Date scheduledDate, Integer nodeId, String nodeGroupId)
protected void	waitAndRunExclusiveAction(String info, Runnable action)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_WORKER_MAX

public static final int DEFAULT_WORKER_MAX

See Also:

Constant Field Values

DEFAULT_POLLING_INTERVAL

public static final int DEFAULT_POLLING_INTERVAL

See Also:

Constant Field Values

DEFAULT_SHUTDOWN_WAIT

public static final int DEFAULT_SHUTDOWN_WAIT

See Also:

Constant Field Values

QUEUE_SIZE_METRIC

public static final String QUEUE_SIZE_METRIC

PROCESSING_TIME_METRIC

public static final String PROCESSING_TIME_METRIC

PROCESSING_HITS_METRIC

public static final String PROCESSING_HITS_METRIC

PROCESSING_MISSES_METRIC

public static final String PROCESSING_MISSES_METRIC

POOLING_TIME_METRIC

public static final String POOLING_TIME_METRIC

POOLING_QUEUE_SIZE_METRIC

public static final String POOLING_QUEUE_SIZE_METRIC

Constructor Detail

DefaultTaskService

public DefaultTaskService()

Method Detail

setModelService

public void setModelService(ModelService modelService)

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)

setTypeService

public void setTypeService(TypeService typeService)

setEventService

public void setEventService(EventService eventService)

setScheduleAndTriggerStrategy

public void setScheduleAndTriggerStrategy(ScheduleAndTriggerStrategy scheduleAndTriggerStrategy)

setMetricRegistry

public void setMetricRegistry(MetricRegistry metricRegistry)

getEngine

public TaskEngine getEngine()

Specified by:

getEngine in interface TaskService

Returns:

the task engine.

isRunning

public boolean isRunning()

triggerRepoll

public void triggerRepoll(Integer nodeId,
                          String nodeGroupId)

Triggers re-poll at the specified cluster node.

Parameters:

nodeId - the cluster node id

triggerEvent

public void triggerEvent(String uniqueId)

Description copied from interface: TaskService

Trigger an event on task module.

Specified by:

triggerEvent in interface TaskService

Parameters:

uniqueId - unique id of event

triggerEvent

public void triggerEvent(String uniqueId,
                         Date expirationDate)

Description copied from interface: TaskService

Trigger an event on task module.

Specified by:

triggerEvent in interface TaskService

Parameters:

uniqueId - unique id of event

expirationDate - expiration date - when reached the task condition created after event send and before

triggerEvent

public boolean triggerEvent(TaskEvent event)

Description copied from interface: TaskService

Trigger event on task module.

Specified by:

triggerEvent in interface TaskService

Parameters:

event - event to be triggered

Returns:

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

scheduleTask

public void scheduleTask(TaskModel task)

Description copied from interface: TaskService

Schedule a task.

Specified by:

scheduleTask in interface TaskService

Parameters:

task - task to schedule.

triggerRepollAfterSchedule

protected void triggerRepollAfterSchedule(Date scheduledDate,
                                          Integer nodeId,
                                          String nodeGroupId)

checkTask

protected void checkTask(TaskModel toBeScheduled)

checkTaskConditions

protected void checkTaskConditions(TaskModel toBeScheduled,
                                   TaskConditionModel cond)

repoll

public void repoll(Integer nodeId,
                   String nodeGroupId)

isAllowedToStart

protected boolean isAllowedToStart()

isAllowedToStart

protected boolean isAllowedToStart(int clusterId)

checkSystemOK

protected boolean checkSystemOK()

init

public void init()

Starts up this component

getTaskDao

protected TaskDAO getTaskDao()

setTaskDao

public void setTaskDao(TaskDAO dao)

readPollingIntervalFromConfig

protected int readPollingIntervalFromConfig()

readMaxWorkersFromConfig

protected int readMaxWorkersFromConfig()

readWorkersIdleFromConfig

protected int readWorkersIdleFromConfig()

readExcludedNodesFromConfig

protected Set<Integer> readExcludedNodesFromConfig()

readShutdownWaitFromConfig

protected int readShutdownWaitFromConfig()

destroy

public void destroy()

Shut down this component

waitAndRunExclusiveAction

protected void waitAndRunExclusiveAction(String info,
                                         Runnable action)

toVersionPKsList

public List<de.hybris.platform.task.impl.DefaultTaskService.VersionPK> toVersionPKsList(List<List<Long>> records)

poll

protected void poll()

getPoolingQueueSizeGauge

protected DefaultTaskService.PoolingQueueSizeGauge getPoolingQueueSizeGauge()

processInTenant

protected void processInTenant(de.hybris.platform.task.impl.DefaultTaskService.VersionPK versionPK)

process

protected void process(de.hybris.platform.task.impl.DefaultTaskService.VersionPK versionPK)

processCondition

protected void processCondition(TaskCondition cond)

processTask

protected void processTask(Task task,
                           de.hybris.platform.task.impl.DefaultTaskService.VersionPK versionPK)

scheduleRetryIfAllowed

protected boolean scheduleRetryIfAllowed(Task task,
                                         RetryLaterException e)

scheduleRetry

protected void scheduleRetry(Task task,
                             Date nextExecution,
                             int turn)

markTaskFailed

protected void markTaskFailed(Task task)

getRunner

protected TaskRunner getRunner(Task task)

getRunner

protected TaskRunner getRunner(String runnerBean)
                        throws IllegalStateException

Throws:

IllegalStateException

getTenant

protected Tenant getTenant()

getExecutionStrategy

protected TaskExecutionStrategy getExecutionStrategy(TaskRunner<? extends TaskModel> runner)

setTaskExecutionStrategies

public void setTaskExecutionStrategies(Collection<? extends TaskExecutionStrategy> taskExecutionStrategies)