Package org.apache.activemq.artemis.utils

Class TokenBucketLimiterImpl

java.lang.Object

org.apache.activemq.artemis.utils.TokenBucketLimiterImpl

All Implemented Interfaces:

TokenBucketLimiter

public class TokenBucketLimiterImpl
extends Object
implements TokenBucketLimiter

Constructor Summary

Constructors

Constructor	Description
TokenBucketLimiterImpl(int rate, boolean spin)
TokenBucketLimiterImpl(int rate, boolean spin, TimeUnit unit, int unitAmount)

Method Summary

Modifier and Type	Method	Description
int	getRate()	Returns the rate in cycles per second (which is the same as saying 'in Hertz').
boolean	isSpin()
void	limit()

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenBucketLimiterImpl

public TokenBucketLimiterImpl(int rate,
                              boolean spin)

TokenBucketLimiterImpl

public TokenBucketLimiterImpl(int rate,
                              boolean spin,
                              TimeUnit unit,
                              int unitAmount)

Method Detail

getRate

public int getRate()

Description copied from interface: TokenBucketLimiter

Returns the rate in cycles per second (which is the same as saying 'in Hertz').

Specified by:

getRate in interface TokenBucketLimiter

See Also:

Hertz

isSpin

public boolean isSpin()

Specified by:

isSpin in interface TokenBucketLimiter

limit

public void limit()

Specified by:

limit in interface TokenBucketLimiter