diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/cache/RecordChangeInfoCacheVmImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/cache/RecordChangeInfoCacheVmImpl.java index 24a3467f8037d4d78b97f034684f31742ca149db..796d13186d5dfe61f97de41ba8a437c28ccbf0a0 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/cache/RecordChangeInfoCacheVmImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/cache/RecordChangeInfoCacheVmImpl.java @@ -25,7 +25,7 @@ public class RecordChangeInfoCacheVmImpl implements IRecordChangeInfoCache { private VmCache<String, RecordChangeInfo> cache; public RecordChangeInfoCacheVmImpl() { - cache = new VmCache<>(Constants.DATA_CACHE_EXPIRATION, Constants.DATA_MAX_CACHE_SIZE); + cache = new VmCache<>(Constants.DATA_CHANGE_INFO_CACHE_EXPIRATION, Constants.DATA_MAX_CACHE_SIZE); } @Override diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/model/Constants.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/model/Constants.java index 2153c214cd09222a98d77e0831f904f1babe6238..5e4588e15b2e965f1468a9c0d0fb8b2063070291 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/model/Constants.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/model/Constants.java @@ -25,5 +25,6 @@ public class Constants { // Data id itself is partition safe public static final int DATA_CACHE_EXPIRATION = 120; + public static final int DATA_CHANGE_INFO_CACHE_EXPIRATION = 3600; public static final int DATA_MAX_CACHE_SIZE = 20000; } diff --git a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/cache/RecordChangeInfoRedisCache.java b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/cache/RecordChangeInfoRedisCache.java index c8ab8ecbb133f7da16cba53fdfbbc6482cc102a7..ed0097159e9a03dbfae6a3cde3f6f2445cd47fb8 100644 --- a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/cache/RecordChangeInfoRedisCache.java +++ b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/cache/RecordChangeInfoRedisCache.java @@ -30,7 +30,7 @@ public class RecordChangeInfoRedisCache extends RedisCache<String, RecordChangeI public RecordChangeInfoRedisCache(final @Named("REDIS_HOST") String host, final @Named("REDIS_PORT") int port, final @Named("REDIS_PASSWORD") String password, - final @Named("RECORDS_REDIS_TTL") int timeout, + final @Named("RECORD_CHANGE_INFO_REDIS_TTL") int timeout, @Value("${redis.database}") final int database) { super(host, port, password, timeout, database, String.class, RecordChangeInfo.class); } diff --git a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/di/RedisConfig.java b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/di/RedisConfig.java index 8ed9134f0ca96064f0977f16b6e36c6289d39d6c..3a98634b81ce1c3729d988dd82cf4110f2eb9bae 100644 --- a/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/di/RedisConfig.java +++ b/provider/indexer-azure/src/main/java/org/opengroup/osdu/indexer/azure/di/RedisConfig.java @@ -41,6 +41,9 @@ public class RedisConfig { @Value("${redis.records.ttl:120}") public int recordsTtl; + @Value("${redis.record.change.info.ttl:3600}") + public int recordChangeInfoTtl; + @Bean @Named("REDIS_PORT") public int getRedisPort() { @@ -71,6 +74,12 @@ public class RedisConfig { return recordsTtl; } + @Bean + @Named("RECORD_CHANGE_INFO_REDIS_TTL") + public int getRecordChangeInfoRedisTtl() { + return recordChangeInfoTtl; + } + @Bean @Named("REDIS_HOST") public String redisHost(SecretClient kv) {