*/
private synchronized void markFailWithRetry(DeliveryTask task) {
working.remove(task.getPublishId());
*/
private synchronized void markFailWithRetry(DeliveryTask task) {
working.remove(task.getPublishId());
long endtime = System.currentTimeMillis() + deliveryQueueHelper.getFairTimeLimit();
int filestogo = deliveryQueueHelper.getFairFileLimit();
while ((task = getNext()) != null) {
long endtime = System.currentTimeMillis() + deliveryQueueHelper.getFairTimeLimit();
int filestogo = deliveryQueueHelper.getFairFileLimit();
while ((task = getNext()) != null) {