From 0abad394436f02ad76c9adde031aaa551fe2b67a Mon Sep 17 00:00:00 2001
From: Luca Frosini <luca.frosini@isti.cnr.it>
Date: Fri, 8 Mar 2024 11:46:07 +0100
Subject: [PATCH] Moved sleep time to the implementation

---
 .../org/gcube/accounting/aggregator/persist/DeleteDocument.java | 2 ++
 .../accounting/aggregator/persist/DocumentElaboration.java      | 1 -
 .../org/gcube/accounting/aggregator/persist/InsertDocument.java | 2 ++
 3 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java b/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java
index 02e727d..e972085 100644
--- a/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java
+++ b/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java
@@ -1,6 +1,7 @@
 package org.gcube.accounting.aggregator.persist;
 
 import java.io.File;
+import java.util.concurrent.TimeUnit;
 
 import org.gcube.accounting.aggregator.persistence.AggregatorPersistenceFactory;
 import org.gcube.accounting.aggregator.persistence.AggregatorPersistenceSrc;
@@ -37,6 +38,7 @@ public class DeleteDocument extends DocumentElaboration {
 			String id = jsonNode.get(ID).asText();
 			logger.trace("Going to delete record with id {}", id);
 			aggregatorPersistenceSrc.deleteRecord(jsonNode);
+			TimeUnit.MILLISECONDS.sleep(2);
 		}
 	}
 
diff --git a/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java b/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java
index 86e1943..0707782 100644
--- a/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java
+++ b/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java
@@ -84,7 +84,6 @@ public abstract class DocumentElaboration {
 					}
 					try {
 						elaborateLine(line);
-						TimeUnit.MILLISECONDS.sleep(3);
 						elaborate = false;
 					} catch(Exception e) {
 						if(i != 1) {
diff --git a/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java b/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java
index b94e855..3233524 100644
--- a/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java
+++ b/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java
@@ -6,6 +6,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.TreeMap;
+import java.util.concurrent.TimeUnit;
 
 import org.gcube.accounting.aggregator.elaboration.Elaborator;
 import org.gcube.accounting.aggregator.persistence.AggregatorPersistenceDst;
@@ -118,6 +119,7 @@ public class InsertDocument extends DocumentElaboration {
 //			count = 0;
 //		}
 		
+		TimeUnit.MILLISECONDS.sleep(2);
 	}
 
 	@Override