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

Class FlowableBucket4jRateLimiter

java.lang.Object

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

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

All Implemented Interfaces:

FlowableRateLimiter, SessionFactory

public class FlowableBucket4jRateLimiter
extends AbstractFlowableRateLimiter

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	FlowableBucket4jRateLimiter.Bucket4JRateLimitCommandContextCloseListener
protected static class	FlowableBucket4jRateLimiter.BucketResetCommandContextCloseListener

Nested classes/interfaces inherited from class com.flowable.platform.engine.impl.sandbox.ratelimiter.bucket4j.AbstractFlowableRateLimiter

AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener

Field Summary

Fields

Modifier and Type	Field	Description
protected final BucketConfigurationProvider	bucketConfigurationProvider
protected final io.github.bucket4j.distributed.proxy.ProxyManager<String>	proxyManager

Constructor Summary

Constructors

Constructor	Description
FlowableBucket4jRateLimiter(io.github.bucket4j.distributed.proxy.ProxyManager<String> proxyManager, BucketConfigurationProvider bucketConfigurationProvider)

Method Summary

Modifier and Type	Method	Description
protected AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener	createCommandContextCloseListener()
protected io.github.bucket4j.Bucket	getBucket(String bucketName, String tenantId, Function<String,io.github.bucket4j.BucketConfiguration> configurationSupplier)
protected void	validateJobExecuteInternal(String jobTenantId)

Methods inherited from class com.flowable.platform.engine.impl.sandbox.ratelimiter.bucket4j.AbstractFlowableRateLimiter

getSessionType, openSession, validateActivityInstanceStart, validateCaseInstanceStart, validateJobCancel, validateJobExecute, validateJobSchedule, validatePlanItemInstanceCreate, validateProcessInstanceStart

Methods inherited from class java.lang.Object

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

Field Details

proxyManager

protected final io.github.bucket4j.distributed.proxy.ProxyManager<String> proxyManager

bucketConfigurationProvider

protected final BucketConfigurationProvider bucketConfigurationProvider

Constructor Details

FlowableBucket4jRateLimiter

public FlowableBucket4jRateLimiter(io.github.bucket4j.distributed.proxy.ProxyManager<String> proxyManager,
 BucketConfigurationProvider bucketConfigurationProvider)

Method Details

validateJobExecuteInternal

protected void validateJobExecuteInternal(String jobTenantId)

Specified by:

validateJobExecuteInternal in class AbstractFlowableRateLimiter

getBucket

protected io.github.bucket4j.Bucket getBucket(String bucketName,
 String tenantId,
 Function<String,io.github.bucket4j.BucketConfiguration> configurationSupplier)

createCommandContextCloseListener

protected AbstractFlowableRateLimiter.RateLimitCommandContextCloseListener createCommandContextCloseListener()

Specified by:

createCommandContextCloseListener in class AbstractFlowableRateLimiter