org.tinygroup.springintegration.ratelimit

Class RateLimitFilter

java.lang.Object

org.tinygroup.springintegration.ratelimit.RateLimitFilter

All Implemented Interfaces:

org.springframework.integration.core.GenericSelector<org.springframework.messaging.Message<?>>, org.springframework.integration.core.MessageSelector

public class RateLimitFilter
extends Object
implements org.springframework.integration.core.MessageSelector

Constructor Summary

Constructors

Constructor and Description
RateLimitFilter()

Method Summary

Modifier and Type	Method and Description
boolean	accept(org.springframework.messaging.Message<?> message)
com.google.common.util.concurrent.RateLimiter	getRateLimiter()
void	setRateLimiter(com.google.common.util.concurrent.RateLimiter rateLimiter)

Methods inherited from class java.lang.Object

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

Constructor Detail

RateLimitFilter

public RateLimitFilter()

Method Detail

getRateLimiter

public com.google.common.util.concurrent.RateLimiter getRateLimiter()

setRateLimiter

public void setRateLimiter(com.google.common.util.concurrent.RateLimiter rateLimiter)

accept

public boolean accept(org.springframework.messaging.Message<?> message)

Specified by:

accept in interface org.springframework.integration.core.GenericSelector<org.springframework.messaging.Message<?>>

Specified by:

accept in interface org.springframework.integration.core.MessageSelector