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

Interface TenantAwareAsyncExecutor

All Superinterfaces:

AsyncExecutor

All Known Implementing Classes:

ExecutorPerTenantAsyncExecutor, SharedExecutorServiceAsyncExecutor

public interface TenantAwareAsyncExecutor
extends AsyncExecutor

Interface for AsyncExecutor implementations used in conjunction with the MultiSchemaMultiTenantProcessEngineConfiguration. Allows to dynamically add tenant executors to the engine.

Author:

Joram Barrez

Method Summary

Modifier and Type	Method	Description
void	addTenantAsyncExecutor(String tenantId, boolean startExecutor)
AsyncExecutor	getTenantAsyncExecutor(String tenantId)
Set<String>	getTenantIds()
void	removeTenantAsyncExecutor(String tenantId)

Methods inherited from interface org.flowable.job.service.impl.asyncexecutor.AsyncExecutor

executeAsyncJob, getAsyncJobLockTimeInMillis, getDefaultAsyncJobAcquireWaitTimeInMillis, getDefaultQueueSizeFullWaitTimeInMillis, getDefaultTimerJobAcquireWaitTimeInMillis, getJobServiceConfiguration, getLockOwner, getMaxAsyncJobsDuePerAcquisition, getMaxTimerJobsPerAcquisition, getResetExpiredJobsInterval, getResetExpiredJobsPageSize, getTaskExecutor, getTimerLockTimeInMillis, isActive, isAutoActivate, setAsyncJobLockTimeInMillis, setAutoActivate, setDefaultAsyncJobAcquireWaitTimeInMillis, setDefaultQueueSizeFullWaitTimeInMillis, setDefaultTimerJobAcquireWaitTimeInMillis, setJobServiceConfiguration, setMaxAsyncJobsDuePerAcquisition, setMaxTimerJobsPerAcquisition, setResetExpiredJobsInterval, setResetExpiredJobsPageSize, setTaskExecutor, setTimerLockTimeInMillis, shutdown, start

Method Details

getTenantIds

Set<String> getTenantIds()

addTenantAsyncExecutor

void addTenantAsyncExecutor(String tenantId,
 boolean startExecutor)

getTenantAsyncExecutor

AsyncExecutor getTenantAsyncExecutor(String tenantId)

removeTenantAsyncExecutor

void removeTenantAsyncExecutor(String tenantId)