fix: Clear the queue before adding new elements

Signed-off-by: Oleg Kopysov <[email protected]>
Samsung · Feb 21, 2024 · 2d29e03 · 2d29e03
1 parent f40dc2b
commit 2d29e03
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/src/main/java/com/lpvs/LicensePreValidationSystem.java b/src/main/java/com/lpvs/LicensePreValidationSystem.java
@@ -71,7 +71,7 @@ public static void main(String[] args) {
     public TaskExecutor getAsyncExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(corePoolSize);
-        executor.setThreadNamePrefix("LPVS-ASYNC::");
+        executor.setThreadNamePrefix("LPVS::");
         return executor;
     }
 }
diff --git a/src/main/java/com/lpvs/service/LPVSQueueService.java b/src/main/java/com/lpvs/service/LPVSQueueService.java
@@ -147,6 +147,7 @@ public BlockingDeque<LPVSQueue> getQueue() {
      * @throws InterruptedException If interrupted while processing the queue.
      */
     public void checkForQueue() throws InterruptedException {
+        QUEUE.clear();
         log.debug("Checking for previous queue");
         List<LPVSQueue> webhookConfigList = queueRepository.getQueueList();
         for (LPVSQueue webhook : webhookConfigList) {

diff --git a/src/test/java/com/lpvs/LicensePreValidationSystemTest.java b/src/test/java/com/lpvs/LicensePreValidationSystemTest.java
@@ -37,7 +37,7 @@ public void testGetAsyncExecutor() {
             assertEquals(executor, mocked_constructed_executor);
 
             verify(mocked_constructed_executor, times(1)).setCorePoolSize(testNumCores);
-            verify(mocked_constructed_executor, times(1)).setThreadNamePrefix("LPVS-ASYNC::");
+            verify(mocked_constructed_executor, times(1)).setThreadNamePrefix("LPVS::");
             verifyNoMoreInteractions(mocked_constructed_executor);
         }
     }