mirror of
https://github.com/Kingsrook/qqq.git
synced 2025-07-18 13:10:44 +00:00
Change to run once an hour, after 6 hours, and to clean 6-hour jobs
This commit is contained in:
@ -46,8 +46,9 @@ public class InMemoryStateProvider implements StateProviderInterface
|
|||||||
|
|
||||||
private final Map<AbstractStateKey, Object> map;
|
private final Map<AbstractStateKey, Object> map;
|
||||||
|
|
||||||
private int jobPeriodSeconds = 60 * 15;
|
private static int jobPeriodSeconds = 60 * 60; // 1 hour
|
||||||
private int jobInitialDelay = 60 * 60 * 4;
|
private static int cleanHours = 6;
|
||||||
|
private static int jobInitialDelay = 60 * 60 * cleanHours;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@ -84,7 +85,7 @@ public class InMemoryStateProvider implements StateProviderInterface
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
Instant cleanTime = Instant.now().minus(4, ChronoUnit.HOURS);
|
Instant cleanTime = Instant.now().minus(cleanHours, ChronoUnit.HOURS);
|
||||||
getInstance().clean(cleanTime);
|
getInstance().clean(cleanTime);
|
||||||
}
|
}
|
||||||
catch(Exception e)
|
catch(Exception e)
|
||||||
|
Reference in New Issue
Block a user