Wrapped execution in a Future to handle workers in parallel.

pme123 · Nov 26, 2024 · b7a83be · b7a83be
1 parent f80e495
commit b7a83be
Showing 1 changed file with 13 additions and 9 deletions.
diff --git a/04-worker-c7spring/src/main/scala/camundala/camunda7/worker/C7WorkerHandler.scala b/04-worker-c7spring/src/main/scala/camundala/camunda7/worker/C7WorkerHandler.scala
@@ -10,14 +10,16 @@ import org.camunda.bpm.client.{ExternalTaskClient, task as camunda}
 import org.springframework.beans.factory.annotation.{Autowired, Value}
 
 import java.util.Date
+import scala.concurrent.ExecutionContext.Implicits.global
+import scala.concurrent.Future
 import scala.jdk.CollectionConverters.*
+import scala.util.{Failure, Success}
 
 /** To avoid Annotations (Camunda Version specific), we extend ExternalTaskHandler for required
   * parameters.
   */
 trait C7WorkerHandler extends camunda.ExternalTaskHandler:
 
-
   @Value("${spring.application.name}")
   var applicationName: String = scala.compiletime.uninitialized
 
@@ -34,14 +36,15 @@ trait C7WorkerHandler extends camunda.ExternalTaskHandler:
       externalTask: camunda.ExternalTask,
       externalTaskService: camunda.ExternalTaskService
   ): Unit =
-    val startDate = new Date()
-    logger.info(
-      s"Worker: ${externalTask.getTopicName} (${externalTask.getId}) started > ${externalTask.getBusinessKey}"
-    )
-    executeWorker(externalTaskService)(using externalTask)
-    logger.info(
-      s"Worker: ${externalTask.getTopicName} (${externalTask.getId}) ended ${printTime(startDate)}   > ${externalTask.getBusinessKey}"
-    )
+    Future:
+      val startDate = new Date()
+      logger.info(
+        s"Worker: ${externalTask.getTopicName} (${externalTask.getId}) started > ${externalTask.getBusinessKey}"
+      )
+      executeWorker(externalTaskService)(using externalTask)
+      logger.info(
+        s"Worker: ${externalTask.getTopicName} (${externalTask.getId}) ended ${printTime(startDate)}   > ${externalTask.getBusinessKey}"
+      )
   end execute
 
   @PostConstruct
@@ -60,6 +63,7 @@ trait C7WorkerHandler extends camunda.ExternalTaskHandler:
       logger.info(
         s"Worker NOT registered: $topic -> ${worker.getClass.getSimpleName} (class starts not with $appPackageName)"
       )
+    end if
   end registerHandler
 
   private def executeWorker(