Package com.flowable.platform.engine.impl.sandbox.ratelimiter

Class RateLimitSession

java.lang.Object

com.flowable.platform.engine.impl.sandbox.ratelimiter.RateLimitSession

All Implemented Interfaces:

org.flowable.common.engine.impl.interceptor.Session

public class RateLimitSession
extends Object
implements org.flowable.common.engine.impl.interceptor.Session

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,AtomicInteger>	activitiesStartedByTenant
protected final Map<String,AtomicInteger>	instancesStartedByTenant
protected final Map<String,Set<org.flowable.job.api.Job>>	jobsScheduledByTenant

Constructor Summary

Constructors

Constructor	Description
RateLimitSession()

Method Summary

Modifier and Type	Method	Description
void	activityStarted(String tenantId)
void	close()
void	flush()
Map<String,AtomicInteger>	getActivitiesStartedByTenant()
Map<String,AtomicInteger>	getInstancesStartedByTenant()
Map<String,Set<org.flowable.job.api.Job>>	getJobsScheduledByTenant()
void	instanceStarted(String tenantId)
static boolean	isJobApplicableForRateLimit(org.flowable.job.api.Job job)
void	jobCanceled(org.flowable.job.api.Job job)
void	jobScheduled(org.flowable.job.api.Job job)

Methods inherited from class java.lang.Object

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

Field Details

instancesStartedByTenant

protected final Map<String,AtomicInteger> instancesStartedByTenant

activitiesStartedByTenant

protected final Map<String,AtomicInteger> activitiesStartedByTenant

jobsScheduledByTenant

protected final Map<String,Set<org.flowable.job.api.Job>> jobsScheduledByTenant

Constructor Details

RateLimitSession

public RateLimitSession()

Method Details

flush

public void flush()

Specified by:

flush in interface org.flowable.common.engine.impl.interceptor.Session

close

public void close()

Specified by:

close in interface org.flowable.common.engine.impl.interceptor.Session

instanceStarted

public void instanceStarted(String tenantId)

activityStarted

public void activityStarted(String tenantId)

jobScheduled

public void jobScheduled(org.flowable.job.api.Job job)

getInstancesStartedByTenant

public Map<String,AtomicInteger> getInstancesStartedByTenant()

jobCanceled

public void jobCanceled(org.flowable.job.api.Job job)

getActivitiesStartedByTenant

public Map<String,AtomicInteger> getActivitiesStartedByTenant()

getJobsScheduledByTenant

public Map<String,Set<org.flowable.job.api.Job>> getJobsScheduledByTenant()

isJobApplicableForRateLimit

public static boolean isJobApplicableForRateLimit(org.flowable.job.api.Job job)