Package akka.contrib.throttle
Class Throttler
- java.lang.Object
-
- akka.contrib.throttle.Throttler
-
public class Throttler extends java.lang.Object
Deprecated.Use streams, see migration guide. Since 2.5.0.A rate used for throttling.Scala API: There are some shorthands available to construct rates:
import java.util.concurrent.TimeUnit._ import scala.concurrent.duration.{ Duration, FiniteDuration } val rate1 = 1 msgsPer (1, SECONDS) val rate2 = 1 msgsPer Duration(1, SECONDS) val rate3 = 1 msgsPer (1 seconds) val rate4 = 1 msgsPerSecond val rate5 = 1 msgsPerMinute val rate6 = 1 msgsPerHour
param: numberOfCalls the number of calls that may take place in a period param: duration the length of the period
- See Also:
Throttler
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Throttler.Rate
Deprecated.static class
Throttler.Rate$
Deprecated.static class
Throttler.RateInt
Deprecated.static class
Throttler.RateInt$
Deprecated.static class
Throttler.SetRate
Deprecated.static class
Throttler.SetRate$
Deprecated.static class
Throttler.SetTarget
Deprecated.static class
Throttler.SetTarget$
Deprecated.
-
Constructor Summary
Constructors Constructor Description Throttler()
Deprecated.
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static Throttler.RateInt
RateInt(int numberOfCalls)
Deprecated.
-
-
-
Method Detail
-
RateInt
public static Throttler.RateInt RateInt(int numberOfCalls)
Deprecated.
-
-