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, org.flowable.common.engine.impl.interceptor.SessionFactory

Direct Known Subclasses:

FlowableBucket4jRateLimiter

public abstract class AbstractFlowableRateLimiter
extends Object
implements FlowableRateLimiter, org.flowable.common.engine.impl.interceptor.SessionFactory

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	SERVICE_TYPE_AI

Constructor Summary

Constructors

Constructor	Description
AbstractFlowableRateLimiter()

Method Summary

Modifier and Type	Method	Description
protected abstract AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener	createCommandContextCloseListener()
Class<?>	getSessionType()
org.flowable.common.engine.impl.interceptor.Session	openSession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
void	validateActivityInstanceStart(org.flowable.engine.runtime.ActivityInstance activityInstance)
protected abstract void	validateAiServiceInvocationInternal(String tenantId)
void	validateCaseInstanceStart(org.flowable.cmmn.api.runtime.CaseInstance caseInstance)
void	validateJobCancel(org.flowable.job.api.Job job)
void	validateJobExecute(org.flowable.job.api.Job job)
protected abstract void	validateJobExecuteInternal(String jobTenantId)
void	validateJobSchedule(org.flowable.job.api.Job job)
void	validatePlanItemInstanceCreate(org.flowable.cmmn.api.runtime.PlanItemInstance planItemInstance)
void	validateProcessInstanceStart(org.flowable.engine.runtime.ProcessInstance processInstance)
void	validateServiceInvocation(ServiceInvocationContext context)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.flowable.platform.engine.impl.sandbox.ratelimiter.FlowableRateLimiter

validateDashboardGeneration, validateDocumentAiInvocation

Field Details

SERVICE_TYPE_AI

protected static final String SERVICE_TYPE_AI

See Also:

• Constant Field Values

Constructor Details

AbstractFlowableRateLimiter

public AbstractFlowableRateLimiter()

Method Details

validateProcessInstanceStart

public void validateProcessInstanceStart(org.flowable.engine.runtime.ProcessInstance processInstance)

Specified by:

validateProcessInstanceStart in interface FlowableRateLimiter

validateActivityInstanceStart

public void validateActivityInstanceStart(org.flowable.engine.runtime.ActivityInstance activityInstance)

Specified by:

validateActivityInstanceStart in interface FlowableRateLimiter

validateCaseInstanceStart

public void validateCaseInstanceStart(org.flowable.cmmn.api.runtime.CaseInstance caseInstance)

Specified by:

validateCaseInstanceStart in interface FlowableRateLimiter

validatePlanItemInstanceCreate

public void validatePlanItemInstanceCreate(org.flowable.cmmn.api.runtime.PlanItemInstance planItemInstance)

Specified by:

validatePlanItemInstanceCreate in interface FlowableRateLimiter

validateJobSchedule

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

Specified by:

validateJobSchedule in interface FlowableRateLimiter

validateJobExecute

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

Specified by:

validateJobExecute in interface FlowableRateLimiter

validateJobCancel

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

Specified by:

validateJobCancel in interface FlowableRateLimiter

validateJobExecuteInternal

protected abstract void validateJobExecuteInternal(String jobTenantId)

validateServiceInvocation

public void validateServiceInvocation(ServiceInvocationContext context)

Specified by:

validateServiceInvocation in interface FlowableRateLimiter

validateAiServiceInvocationInternal

protected abstract void validateAiServiceInvocationInternal(String tenantId)

getSessionType

public Class<?> getSessionType()

Specified by:

getSessionType in interface org.flowable.common.engine.impl.interceptor.SessionFactory

openSession

public org.flowable.common.engine.impl.interceptor.Session openSession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

Specified by:

openSession in interface org.flowable.common.engine.impl.interceptor.SessionFactory

createCommandContextCloseListener

protected abstract AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener createCommandContextCloseListener()