Package org.flowable.job.service.impl.asyncexecutor.multitenant

Class TenantAwareAcquireAsyncJobsDueRunnable

java.lang.Object

org.flowable.job.service.impl.asyncexecutor.AcquireAsyncJobsDueRunnable

org.flowable.job.service.impl.asyncexecutor.multitenant.TenantAwareAcquireAsyncJobsDueRunnable

All Implemented Interfaces:

Runnable

public class TenantAwareAcquireAsyncJobsDueRunnable
extends AcquireAsyncJobsDueRunnable

Extends the default AcquireAsyncJobsDueRunnable by setting the 'tenant' context before executing.

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected String	tenantId
protected TenantInfoHolder	tenantInfoHolder

Fields inherited from class org.flowable.job.service.impl.asyncexecutor.AcquireAsyncJobsDueRunnable

asyncExecutor, configuration, isInterrupted, isWaiting, jobEntityManager, lifecycleListener, lockManager, MONITOR, name

Constructor Summary

Constructors

Constructor	Description
TenantAwareAcquireAsyncJobsDueRunnable(AsyncExecutor asyncExecutor, TenantInfoHolder tenantInfoHolder, String tenantId)
TenantAwareAcquireAsyncJobsDueRunnable(AsyncExecutor asyncExecutor, TenantInfoHolder tenantInfoHolder, String tenantId, AcquireAsyncJobsDueLifecycleListener lifecycleListener, AcquireJobsRunnableConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
protected ExecutorPerTenantAsyncExecutor	getTenantAwareAsyncExecutor()
void	run()

Methods inherited from class org.flowable.job.service.impl.asyncexecutor.AcquireAsyncJobsDueRunnable

acquireAndExecuteJobs, createLockManager, executeAcquireCycle, getEngineName, getLifecycleListener, offerJobs, setConfiguration, setLifecycleListener, sleep, stop

Methods inherited from class java.lang.Object

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

Field Details

tenantInfoHolder

protected TenantInfoHolder tenantInfoHolder

tenantId

protected String tenantId

Constructor Details

TenantAwareAcquireAsyncJobsDueRunnable

public TenantAwareAcquireAsyncJobsDueRunnable(AsyncExecutor asyncExecutor,
 TenantInfoHolder tenantInfoHolder,
 String tenantId)

TenantAwareAcquireAsyncJobsDueRunnable

public TenantAwareAcquireAsyncJobsDueRunnable(AsyncExecutor asyncExecutor,
 TenantInfoHolder tenantInfoHolder,
 String tenantId,
 AcquireAsyncJobsDueLifecycleListener lifecycleListener,
 AcquireJobsRunnableConfiguration configuration)

Method Details

getTenantAwareAsyncExecutor

protected ExecutorPerTenantAsyncExecutor getTenantAwareAsyncExecutor()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class AcquireAsyncJobsDueRunnable