Fixing bug on buffer overfilling

open4good · Dec 10, 2023 · 9735a52 · 9735a52
1 parent 35ee820
commit 9735a52
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/api/src/main/java/org/open4goods/api/services/store/DataFragmentStoreService.java b/api/src/main/java/org/open4goods/api/services/store/DataFragmentStoreService.java
@@ -227,15 +227,12 @@ public void aggregateAndstore() {
 
 			logger.info("Indexed {} DataFragments in {}ms.",  buffer.size(),System.currentTimeMillis()-now);
 
-			// Clearing queue
-			fileQueue.clear();
-
-
-
 		} catch (final Exception e) {
 			logger.error("Error while dequeing DataFragments",e);
 		}
 
+		// Clearing queue
+		fileQueue.clear();
 
 	}