akka.contrib.throttle
Class Throttler.RateInt

java.lang.Object
  extended by scala.AnyVal
      extended by akka.contrib.throttle.Throttler.RateInt
Enclosing interface:
Throttler

public static class Throttler.RateInt
extends scala.AnyVal

Helper for some syntactic sugar.

See Also:
Throttler.Rate

Constructor Summary
Throttler.RateInt(int numberOfCalls)
           
 
Method Summary
 Throttler.Rate msgsPer(scala.concurrent.duration.FiniteDuration duration)
           
 Throttler.Rate msgsPer(int duration, java.util.concurrent.TimeUnit timeUnit)
           
 Throttler.Rate msgsPerHour()
           
 Throttler.Rate msgsPerMinute()
           
 Throttler.Rate msgsPerSecond()
           
 int numberOfCalls()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Throttler.RateInt

public Throttler.RateInt(int numberOfCalls)
Method Detail

numberOfCalls

public int numberOfCalls()

msgsPer

public Throttler.Rate msgsPer(int duration,
                              java.util.concurrent.TimeUnit timeUnit)

msgsPer

public Throttler.Rate msgsPer(scala.concurrent.duration.FiniteDuration duration)

msgsPerSecond

public Throttler.Rate msgsPerSecond()

msgsPerMinute

public Throttler.Rate msgsPerMinute()

msgsPerHour

public Throttler.Rate msgsPerHour()