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

Class AbstractFlowableRateLimiter

java.lang.Object

com.flowable.platform.engine.impl.sandbox.ratelimiter.bucket4j.AbstractFlowableRateLimiter

All Implemented Interfaces:

FlowableRateLimiter, SessionFactory

Direct Known Subclasses:

FlowableBucket4jRateLimiter

public abstract class AbstractFlowableRateLimiter
extends Object
implements FlowableRateLimiter, SessionFactory

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener

Constructor Summary

Constructors

Constructor	Description
AbstractFlowableRateLimiter()

Method Summary

Modifier and Type	Method	Description
protected abstract AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener	createCommandContextCloseListener()
Class<?>	getSessionType()
Session	openSession(CommandContext commandContext)
void	validateActivityInstanceStart(ActivityInstance activityInstance)
void	validateCaseInstanceStart(CaseInstance caseInstance)
void	validateJobCancel(Job job)
void	validateJobExecute(Job job)
protected abstract void	validateJobExecuteInternal(String jobTenantId)
void	validateJobSchedule(Job job)
void	validatePlanItemInstanceCreate(PlanItemInstance planItemInstance)
void	validateProcessInstanceStart(ProcessInstance processInstance)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractFlowableRateLimiter

public AbstractFlowableRateLimiter()

Method Details

validateProcessInstanceStart

public void validateProcessInstanceStart(ProcessInstance processInstance)

Specified by:

validateProcessInstanceStart in interface FlowableRateLimiter

validateActivityInstanceStart

public void validateActivityInstanceStart(ActivityInstance activityInstance)

Specified by:

validateActivityInstanceStart in interface FlowableRateLimiter

validateCaseInstanceStart

public void validateCaseInstanceStart(CaseInstance caseInstance)

Specified by:

validateCaseInstanceStart in interface FlowableRateLimiter

validatePlanItemInstanceCreate

public void validatePlanItemInstanceCreate(PlanItemInstance planItemInstance)

Specified by:

validatePlanItemInstanceCreate in interface FlowableRateLimiter

validateJobSchedule

public void validateJobSchedule(Job job)

Specified by:

validateJobSchedule in interface FlowableRateLimiter

validateJobExecute

public void validateJobExecute(Job job)

Specified by:

validateJobExecute in interface FlowableRateLimiter

validateJobCancel

public void validateJobCancel(Job job)

Specified by:

validateJobCancel in interface FlowableRateLimiter

validateJobExecuteInternal

protected abstract void validateJobExecuteInternal(String jobTenantId)

getSessionType

public Class<?> getSessionType()

Specified by:

getSessionType in interface SessionFactory

openSession

public Session openSession(CommandContext commandContext)

Specified by:

openSession in interface SessionFactory

createCommandContextCloseListener

protected abstract AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener createCommandContextCloseListener()