Package de.hybris.platform.ruleengine.concurrency.impl

Class DefaultSuspendResumeTaskManager

java.lang.Object

de.hybris.platform.ruleengine.concurrency.impl.DefaultSuspendResumeTaskManager

All Implemented Interfaces:

SuspendResumeTaskManager

public class DefaultSuspendResumeTaskManager
extends java.lang.Object
implements SuspendResumeTaskManager

Default implementation of SuspendResumeTaskManager.

Constructor Summary

Constructors

Constructor	Description
DefaultSuspendResumeTaskManager()

Method Summary

Modifier and Type	Method	Description
protected Tenant	getCurrentTenant()
protected SuspendResumeService	getSuspendResumeService()
boolean	isSystemRunning()	Query id the system is in the running state
void	registerAsNonSuspendableTask(java.lang.Thread task, java.lang.String statusInfo)	Try to register the task as NonSuspendable thread
void	registerAsSuspendableTask(java.lang.Thread task, java.lang.String statusInfo)	Try to register the task as Suspendable thread
void	setCurrentTenant(Tenant currentTenant)
void	setSuspendResumeService(SuspendResumeService suspendResumeService)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSuspendResumeTaskManager

public DefaultSuspendResumeTaskManager()

Method Detail

registerAsNonSuspendableTask

public void registerAsNonSuspendableTask(java.lang.Thread task,
                                         java.lang.String statusInfo)

Description copied from interface: SuspendResumeTaskManager

Try to register the task as NonSuspendable thread

Specified by:

registerAsNonSuspendableTask in interface SuspendResumeTaskManager

Parameters:

task - instance of Thread to register

statusInfo - status info to expose to framework

registerAsSuspendableTask

public void registerAsSuspendableTask(java.lang.Thread task,
                                      java.lang.String statusInfo)

Description copied from interface: SuspendResumeTaskManager

Try to register the task as Suspendable thread

Specified by:

registerAsSuspendableTask in interface SuspendResumeTaskManager

Parameters:

task - instance of Thread to register

statusInfo - status info to expose to framework

isSystemRunning

public boolean isSystemRunning()

Description copied from interface: SuspendResumeTaskManager

Query id the system is in the running state

Specified by:

isSystemRunning in interface SuspendResumeTaskManager

Returns:

true if the system is running, false otherwise

getCurrentTenant

protected Tenant getCurrentTenant()

setCurrentTenant

public void setCurrentTenant(Tenant currentTenant)

getSuspendResumeService

protected SuspendResumeService getSuspendResumeService()

setSuspendResumeService

public void setSuspendResumeService(SuspendResumeService suspendResumeService)