org.globus.cog.karajan.scheduler.submitQueue
Class RateLimiterQueue
java.lang.Object
org.globus.cog.karajan.scheduler.submitQueue.AbstractSubmitQueue
org.globus.cog.karajan.scheduler.submitQueue.RateLimiterQueue
- All Implemented Interfaces:
- StatusListener, SubmitQueue
public class RateLimiterQueue
- extends AbstractSubmitQueue
- implements StatusListener
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEFAULT_MAX_RETRIES
public static final int DEFAULT_MAX_RETRIES
- See Also:
- Constant Field Values
RateLimiterQueue
public RateLimiterQueue(int initialRate,
int maxRetries,
String errorRegexp)
setRate
public void setRate(int rate)
step
protected void step()
- Overrides:
step
in class AbstractSubmitQueue
submitCompleted
public void submitCompleted(NonBlockingSubmit old,
Exception ex)
- Specified by:
submitCompleted
in interface SubmitQueue
- Overrides:
submitCompleted
in class AbstractSubmitQueue
statusChanged
public void statusChanged(StatusEvent event)
- Specified by:
statusChanged
in interface StatusListener