com.northconcepts.datapipeline.throttle
Class Throttle

java.lang.Object
  com.northconcepts.datapipeline.throttle.Throttle

public class Throttle
extends Object

Constructor Summary

Throttle(Meter meter, int unitsPerSecond)

Method Summary

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)