diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/InMemoryStateProvider.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/InMemoryStateProvider.java index e63a43ad..52d756ec 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/InMemoryStateProvider.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/InMemoryStateProvider.java @@ -46,8 +46,8 @@ public class InMemoryStateProvider implements StateProviderInterface private final Map map; - private static int jobPeriodSeconds = 60 * 60; // 1 hour - private static int cleanHours = 6; + private static int jobPeriodSeconds = 60 * 30; // 30 minutes + private static int cleanHours = 5; private static int jobInitialDelay = 60 * 60 * cleanHours; @@ -151,6 +151,18 @@ public class InMemoryStateProvider implements StateProviderInterface + /******************************************************************************* + ** Get the current status + * + *******************************************************************************/ + @Override + public String status() + { + return ("InMemoryStateProvider map size: " + map.size()); + } + + + /******************************************************************************* ** Clean entries that started before the given Instant * diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/StateProviderInterface.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/StateProviderInterface.java index c08558d5..43794edd 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/StateProviderInterface.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/StateProviderInterface.java @@ -59,6 +59,11 @@ public interface StateProviderInterface *******************************************************************************/ void remove(AbstractStateKey key); + /******************************************************************************* + ** Get the current status + *******************************************************************************/ + String status(); + /******************************************************************************* ** Clean entries that started before the given Instant *******************************************************************************/ diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/TempFileStateProvider.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/TempFileStateProvider.java index 02ab06a9..f4f3dc42 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/TempFileStateProvider.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/state/TempFileStateProvider.java @@ -127,6 +127,18 @@ public class TempFileStateProvider implements StateProviderInterface + /******************************************************************************* + ** Get the current status + * + *******************************************************************************/ + @Override + public String status() + { + return ("TempFileStateProvider status not supported"); + } + + + /******************************************************************************* ** Clean entries that started before the given Instant *******************************************************************************/