com.northconcepts.datapipeline.throttle

Class Throttle

java.lang.Object

com.northconcepts.datapipeline.throttle.Throttle

public class Throttle
extends Object

Constructor Summary

Constructors

Constructor and Description
Throttle(Meter meter, int unitsPerSecond)

Method Summary

Modifier and Type	Method and Description
DataException	addExceptionProperties(DataException exception)
Meter	getMeter()
double	getPeekUnitsPerSecond()
int	getUnitsPerSecond()
void	setUnitsPerSecond(int unitsPerSecond)
void	throttle()

Methods inherited from class java.lang.Object

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

Constructor Detail

Throttle

public Throttle(Meter meter,
                int unitsPerSecond)

Method Detail

getMeter

public Meter getMeter()

getUnitsPerSecond

public int getUnitsPerSecond()

setUnitsPerSecond

public void setUnitsPerSecond(int unitsPerSecond)

getPeekUnitsPerSecond

public double getPeekUnitsPerSecond()

throttle

public void throttle()
              throws InterruptedException

Throws:

InterruptedException

addExceptionProperties

public DataException addExceptionProperties(DataException exception)