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

Class RateLimitSession

java.lang.Object

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

All Implemented Interfaces:

Session

public class RateLimitSession
extends Object
implements 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<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<Job>>	getJobsScheduledByTenant()
void	instanceStarted(String tenantId)
static boolean	isJobApplicableForRateLimit(Job job)
void	jobCanceled(Job job)
void	jobScheduled(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<Job>> jobsScheduledByTenant

Constructor Details

RateLimitSession

public RateLimitSession()

Method Details

flush

public void flush()

Specified by:

flush in interface Session

close

public void close()

Specified by:

close in interface Session

instanceStarted

public void instanceStarted(String tenantId)

activityStarted

public void activityStarted(String tenantId)

jobScheduled

public void jobScheduled(Job job)

getInstancesStartedByTenant

public Map<String,AtomicInteger> getInstancesStartedByTenant()

jobCanceled

public void jobCanceled(Job job)

getActivitiesStartedByTenant

public Map<String,AtomicInteger> getActivitiesStartedByTenant()

getJobsScheduledByTenant

public Map<String,Set<Job>> getJobsScheduledByTenant()

isJobApplicableForRateLimit

public static boolean isJobApplicableForRateLimit(Job job)