Evict APN retry job after 90 days unseen
This commit is contained in:
parent
dac9cee7ca
commit
40bac000ab
|
@ -21,6 +21,7 @@ import java.util.Arrays;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
|
|
||||||
import static com.codahale.metrics.MetricRegistry.name;
|
import static com.codahale.metrics.MetricRegistry.name;
|
||||||
|
@ -147,6 +148,14 @@ public class ApnFallbackManager implements Managed, Runnable {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
long deviceLastSeen = device.get().getLastSeen();
|
||||||
|
|
||||||
|
if (deviceLastSeen < System.currentTimeMillis() - TimeUnit.DAYS.toMillis(90)) {
|
||||||
|
logger.info("Evicting retry after 90 days: " + account.get().getNumber() + ", " + device.get().getId());
|
||||||
|
removeOperation.remove(account.get(), device.get());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
apnSender.sendMessage(new ApnMessage(apnId, separated.get().first(), separated.get().second(), true));
|
apnSender.sendMessage(new ApnMessage(apnId, separated.get().first(), separated.get().second(), true));
|
||||||
retry.mark();
|
retry.mark();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue