org.springframework.integration.handler.advice

Class RateLimiterRequestHandlerAdvice

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice

org.springframework.integration.handler.advice.RateLimiterRequestHandlerAdvice

All Implemented Interfaces:

Advice, Interceptor, MethodInterceptor, Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ExpressionCapable, NamedComponent

public class RateLimiterRequestHandlerAdvice
extends AbstractRequestHandlerAdvice

An AbstractRequestHandlerAdvice extension for a rate limiting to service method calls. The implementation is based on the Resilience4j.

Since:

5.2

Author:

Artem Bilan, Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RateLimiterRequestHandlerAdvice.RateLimitExceededException A MessagingException wrapper for the RequestNotPermitted with the requestMessage and target context.

Nested classes/interfaces inherited from class org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice

AbstractRequestHandlerAdvice.ExecutionCallback, AbstractRequestHandlerAdvice.ThrowableHolderException

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_NAME

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Constructor Summary

Constructors

Constructor and Description
RateLimiterRequestHandlerAdvice() Construct an instance based on default rate limiter options and "RateLimiterRequestHandlerAdvice" as a rate limiter name.
RateLimiterRequestHandlerAdvice(io.github.resilience4j.ratelimiter.RateLimiter rateLimiter) Construct an instance based on the provided RateLimiter.
RateLimiterRequestHandlerAdvice(io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig) Construct an instance based on the provided RateLimiterConfig and "RateLimiterRequestHandlerAdvice" as a rate limiter name.
RateLimiterRequestHandlerAdvice(io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig, String name) Construct an instance based on the provided RateLimiterConfig and name.
RateLimiterRequestHandlerAdvice(String name) Construct an instance based on default rate limiter options and provided name.

Method Summary

Modifier and Type	Method and Description
protected Object	doInvoke(AbstractRequestHandlerAdvice.ExecutionCallback callback, Object target, Message<?> message) Subclasses implement this method to apply behavior to the MessageHandler.
io.github.resilience4j.ratelimiter.RateLimiter.Metrics	getMetrics() Obtain the metrics from the rate limiter.
io.github.resilience4j.ratelimiter.RateLimiter	getRateLimiter() Get the RateLimiter which is configured for this advice.
void	setLimitForPeriod(int limitForPeriod) Change the limitForPeriod option of the rateLimiter.
void	setTimeoutDuration(java.time.Duration timeoutDuration) Change the timeoutDuration option of the rateLimiter.

Methods inherited from class org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice

invoke, unwrapExceptionIfNecessary, unwrapThrowableIfNecessary

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_NAME

public static final String DEFAULT_NAME

See Also:

Constant Field Values

Constructor Detail

RateLimiterRequestHandlerAdvice

public RateLimiterRequestHandlerAdvice()

Construct an instance based on default rate limiter options and "RateLimiterRequestHandlerAdvice" as a rate limiter name.

See Also:

RateLimiter.ofDefaults(java.lang.String)

RateLimiterRequestHandlerAdvice

public RateLimiterRequestHandlerAdvice(String name)

Construct an instance based on default rate limiter options and provided name.

Parameters:

name - the name for the rate limiter.

RateLimiterRequestHandlerAdvice

public RateLimiterRequestHandlerAdvice(io.github.resilience4j.ratelimiter.RateLimiter rateLimiter)

Construct an instance based on the provided RateLimiter.

Parameters:

rateLimiter - the RateLimiter to use.

RateLimiterRequestHandlerAdvice

public RateLimiterRequestHandlerAdvice(io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig)

Construct an instance based on the provided RateLimiterConfig and "RateLimiterRequestHandlerAdvice" as a rate limiter name.

Parameters:

rateLimiterConfig - the RateLimiterConfig to use.

RateLimiterRequestHandlerAdvice

public RateLimiterRequestHandlerAdvice(io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig,
                                       String name)

Construct an instance based on the provided RateLimiterConfig and name.

Parameters:

rateLimiterConfig - the RateLimiterConfig to use.

name - the name for the rate limiter.

Method Detail

setLimitForPeriod

public void setLimitForPeriod(int limitForPeriod)

Change the limitForPeriod option of the rateLimiter.

Parameters:

limitForPeriod - the limitForPeriod to use.

See Also:

RateLimiter.changeLimitForPeriod(int)

setTimeoutDuration

public void setTimeoutDuration(java.time.Duration timeoutDuration)

Change the timeoutDuration option of the rateLimiter.

Parameters:

timeoutDuration - the timeoutDuration to use.

See Also:

RateLimiter.changeTimeoutDuration(Duration)

getMetrics

public io.github.resilience4j.ratelimiter.RateLimiter.Metrics getMetrics()

Obtain the metrics from the rate limiter.

Returns:

the RateLimiter.Metrics from rate limiter.

See Also:

RateLimiter.getMetrics()

getRateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter getRateLimiter()

Get the RateLimiter which is configured for this advice.

Returns:

the RateLimiter for this advice.

doInvoke

protected Object doInvoke(AbstractRequestHandlerAdvice.ExecutionCallback callback,
                          Object target,
                          Message<?> message)

Description copied from class: AbstractRequestHandlerAdvice

Subclasses implement this method to apply behavior to the MessageHandler.

callback.execute() invokes the handler method and returns its result, or null.

Specified by:

doInvoke in class AbstractRequestHandlerAdvice

Parameters:

callback - Subclasses invoke the execute() method on this interface to invoke the handler method.

target - The target handler.

message - The message that will be sent to the handler.

Returns:

the result after invoking the MessageHandler.