public static class RateLimitPolicyFactory.DelayIntervalRateLimiter extends java.lang.Object implements RateLimitPolicy
Constructor and Description |
---|
DelayIntervalRateLimiter() |
DelayIntervalRateLimiter(java.util.function.Supplier<Duration> delay) |
Modifier and Type | Method and Description |
---|---|
void |
onSuccess(java.util.List<KinesisRecord> records)
Called after Kinesis records are successfully retrieved.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onThrottle
public DelayIntervalRateLimiter()
public DelayIntervalRateLimiter(java.util.function.Supplier<Duration> delay)
public void onSuccess(java.util.List<KinesisRecord> records) throws java.lang.InterruptedException
RateLimitPolicy
onSuccess
in interface RateLimitPolicy
records
- The list of retrieved records.java.lang.InterruptedException