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

Modifier and Type	Method	Description
static Throttler.RateInt	RateInt(int numberOfCalls)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

Throttler

public Throttler()

Deprecated.

Method Detail

RateInt

public static Throttler.RateInt RateInt(int numberOfCalls)

Deprecated.