Interface DelayingQueue<T>

Type Parameters:

T - item type

All Superinterfaces:

WorkQueue<T>

All Known Subinterfaces:

RateLimitingQueue<T>

All Known Implementing Classes:

DefaultDelayingQueue, DefaultRateLimitingQueue

public interface DelayingQueue<T>
extends WorkQueue<T>

Defines a queue that can add an item at a later time. This makes it easier to requeue items after failures without ending up in a hot-loop.

The code has been copied from the official client and modified: DelayingQueue

Method Summary

Modifier and Type	Method	Description
void	addAfter(T item, Duration duration)	Adds an item to the workqueue after the indicated duration has passed.

Methods inherited from interface WorkQueue

add, done, get, isShutdown, length, shutdown, start

Method Details

addAfter

void addAfter(T item,
 Duration duration)

Adds an item to the workqueue after the indicated duration has passed.

Parameters:

item - item to add

duration - specific duration