org.asynchttpclient.extras.guava

Class RateLimitedThrottleRequestFilter

java.lang.Object

org.asynchttpclient.extras.guava.RateLimitedThrottleRequestFilter

All Implemented Interfaces:

RequestFilter

public class RateLimitedThrottleRequestFilter
extends Object
implements RequestFilter

A RequestFilter that extends the capability of ThrottleRequestFilter by allowing rate limiting per second in addition to the number of concurrent connections.

The maxWaitMs argument is respected across both permit acquisitions. For example, if 1000 ms is given, and the filter spends 500 ms waiting for a connection, it will only spend another 500 ms waiting for the rate limiter.

Constructor Summary

Constructors

Constructor and Description
RateLimitedThrottleRequestFilter(int maxConnections, double rateLimitPerSecond)
RateLimitedThrottleRequestFilter(int maxConnections, double rateLimitPerSecond, int maxWaitMs)

Method Summary

Modifier and Type	Method and Description
<T> FilterContext<T>	filter(FilterContext<T> ctx)

Methods inherited from class java.lang.Object

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

Constructor Detail

RateLimitedThrottleRequestFilter

public RateLimitedThrottleRequestFilter(int maxConnections,
                                        double rateLimitPerSecond)

RateLimitedThrottleRequestFilter

public RateLimitedThrottleRequestFilter(int maxConnections,
                                        double rateLimitPerSecond,
                                        int maxWaitMs)

Method Detail

filter

public <T> FilterContext<T> filter(FilterContext<T> ctx)
                            throws FilterException

Specified by:

filter in interface RequestFilter

Throws:

FilterException