- All Implemented Interfaces:
An implementation of
RateControl that limits the number of
events within a time period.
Events are kept in a queue and for each event the queue is first
drained of the old events outside the time window, and then the new
event is added to the queue. The size of the queue is maintained
separately in an AtomicInteger and if it exceeds the max
number of events then
Nested Class SummaryModifier and TypeClassDescription
(int maxEvents, Duration window)
fromEventsPerSecondpublic static WindowRateControl fromEventsPerSecond
getEventsPerSecondpublic int getEventsPerSecond()
onEventpublic boolean onEvent
(Object event)Description copied from interface:
Applications should call this method when they want to signal an event that is subject to rate control.
Implementations should return true if the event does not exceed the desired rate, or false to signal that the event exceeded the desired rate.