fix: sync locks

ministero-salute · Dec 19, 2023 · 93cb9d7 · 93cb9d7
1 parent 62d7925
commit 93cb9d7
Showing 1 changed file with 14 additions and 5 deletions.
diff --git a/src/main/java/it/finanze/sanita/fse2/ms/gtw/dispatcher/service/impl/ConfigSRV.java b/src/main/java/it/finanze/sanita/fse2/ms/gtw/dispatcher/service/impl/ConfigSRV.java
@@ -52,7 +52,7 @@ public void postConstruct() {
 	public Boolean isRemoveEds() {
 		long lastUpdate = props.get(PROPS_NAME_REMOVE_EDS_ENABLE).getKey();
 		if (new Date().getTime() - lastUpdate >= DELTA_MS) {
-			synchronized(PROPS_NAME_REMOVE_EDS_ENABLE) {
+			synchronized(Locks.REMOVE_EDS_ENABLE) {
 				if (new Date().getTime() - lastUpdate >= DELTA_MS) {
 					refresh(PROPS_NAME_REMOVE_EDS_ENABLE);
 				}
@@ -65,7 +65,7 @@ public Boolean isRemoveEds() {
     public Boolean isAuditEnable() {
         long lastUpdate = props.get(PROPS_NAME_AUDIT_ENABLED).getKey();
         if (new Date().getTime() - lastUpdate >= DELTA_MS) {
-            synchronized(PROPS_NAME_CONTROL_LOG_ENABLED) {
+            synchronized(Locks.AUDIT_ENABLED) {
                 if (new Date().getTime() - lastUpdate >= DELTA_MS) {
                     refresh(PROPS_NAME_AUDIT_ENABLED);
                 }
@@ -80,7 +80,7 @@ public Boolean isAuditEnable() {
     public Boolean isControlLogPersistenceEnable() {
         long lastUpdate = props.get(PROPS_NAME_CONTROL_LOG_ENABLED).getKey();
         if (new Date().getTime() - lastUpdate >= DELTA_MS) {
-            synchronized(PROPS_NAME_CONTROL_LOG_ENABLED) {
+            synchronized(Locks.CONTROL_LOG_ENABLED) {
                 if (new Date().getTime() - lastUpdate >= DELTA_MS) {
                     refresh(PROPS_NAME_CONTROL_LOG_ENABLED);
                 }
@@ -95,7 +95,7 @@ public Boolean isControlLogPersistenceEnable() {
 	public Boolean isSubjectNotAllowed() {
 		long lastUpdate = props.get(PROPS_NAME_SUBJECT).getKey();
 		if (new Date().getTime() - lastUpdate >= DELTA_MS) {
-			synchronized (PROPS_NAME_SUBJECT) {
+			synchronized (Locks.SUBJECT_CLEANING) {
 				if (new Date().getTime() - lastUpdate >= DELTA_MS) {
 					refresh(PROPS_NAME_SUBJECT);
 				}
@@ -110,7 +110,7 @@ public Boolean isSubjectNotAllowed() {
 	public Boolean isCfOnIssuerNotAllowed() {
 		long lastUpdate = props.get(PROPS_NAME_ISSUER_CF).getKey();
 		if (new Date().getTime() - lastUpdate >= DELTA_MS) {
-			synchronized(PROPS_NAME_ISSUER_CF) {
+			synchronized(Locks.ISSUER_CF_CLEANING) {
 				if (new Date().getTime() - lastUpdate >= DELTA_MS) {
 					refresh(PROPS_NAME_ISSUER_CF);
 				}
@@ -156,4 +156,13 @@ private void init() {
         }
         integrity();
     }
+
+    private static class Locks {
+        public static final Object REMOVE_EDS_ENABLE = new Object();
+        public static final Object CONTROL_LOG_ENABLED = new Object();
+        public static final Object AUDIT_ENABLED = new Object();
+        public static final Object ISSUER_CF_CLEANING = new Object();
+        public static final Object SUBJECT_CLEANING = new Object();
+    }
+
 }