From 3550ed71d90e33c451871c7ecde9fc38c67c03ba Mon Sep 17 00:00:00 2001 From: LSmyrnaios Date: Fri, 11 Jun 2021 13:44:33 +0300 Subject: [PATCH] Execute the "AssignmentHandler.handleAssignment()", only from the scheduler, as it starts automatically when the program starts. --- .../java/eu/openaire/urls_worker/UrlsWorkerApplication.java | 4 +--- .../java/eu/openaire/urls_worker/util/AssignmentHandler.java | 4 +++- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/eu/openaire/urls_worker/UrlsWorkerApplication.java b/src/main/java/eu/openaire/urls_worker/UrlsWorkerApplication.java index 86e0d72..b2c4584 100644 --- a/src/main/java/eu/openaire/urls_worker/UrlsWorkerApplication.java +++ b/src/main/java/eu/openaire/urls_worker/UrlsWorkerApplication.java @@ -1,6 +1,6 @@ package eu.openaire.urls_worker; -import eu.openaire.urls_worker.util.AssignmentHandler; + import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.scheduling.annotation.EnableScheduling; @@ -12,8 +12,6 @@ public class UrlsWorkerApplication { public static void main(String[] args) { SpringApplication.run(UrlsWorkerApplication.class, args); - - AssignmentHandler.handleAssignment(); } } diff --git a/src/main/java/eu/openaire/urls_worker/util/AssignmentHandler.java b/src/main/java/eu/openaire/urls_worker/util/AssignmentHandler.java index 93946d0..2e420d9 100644 --- a/src/main/java/eu/openaire/urls_worker/util/AssignmentHandler.java +++ b/src/main/java/eu/openaire/urls_worker/util/AssignmentHandler.java @@ -19,7 +19,7 @@ public class AssignmentHandler { private static final Logger logger = LoggerFactory.getLogger(AssignmentHandler.class); - public static boolean isAvailableForWork = false; + public static boolean isAvailableForWork = true; public static Assignment requestAssignment() { @@ -65,6 +65,8 @@ public class AssignmentHandler { logger.warn("The assignment was found to be null!"); return; } + + // Start handling the assignment, the worker is busy. isAvailableForWork = false; List tasks = assignment.getTasks();