Add logs

camunda-community-hub · Aug 19, 2024 · c4a75b3 · c4a75b3
1 parent 1d25b7f
commit c4a75b3
Show file tree

Hide file tree

Showing 5 changed files with 36 additions and 20 deletions.
diff --git a/README.md b/README.md
@@ -344,23 +344,23 @@ mvn clean install
 ````
 Now, create a docker image
 ````
-docker build -t pierre-yves-monnet/processautomator:1.6.0 .
+docker build -t pierre-yves-monnet/processautomator:1.7.0 .
 
 ````
 
 
 Push the image to the Camunda hub (you must be login first to the docker registry)
 
 ````
-docker tag pierre-yves-monnet/processautomator:1.6.0 ghcr.io/camunda-community-hub/process-execution-automator:1.6.0
-docker push ghcr.io/camunda-community-hub/process-execution-automator:1.6.0
+docker tag pierre-yves-monnet/processautomator:1.7.0 ghcr.io/camunda-community-hub/process-execution-automator:1.7.0
+docker push ghcr.io/camunda-community-hub/process-execution-automator:1.7.0
 
 ````
 
 
 Tag as the latest:
 ````
-docker tag pierre-yves-monnet/processautomator:1.6.0 ghcr.io/camunda-community-hub/process-execution-automator:latest
+docker tag pierre-yves-monnet/processautomator:1.7.0 ghcr.io/camunda-community-hub/process-execution-automator:latest
 docker push ghcr.io/camunda-community-hub/process-execution-automator:latest
 ````
 

diff --git a/pom.xml b/pom.xml
@@ -6,9 +6,11 @@
   <groupId>org.camunda.community.automator</groupId>
   <artifactId>process-execution-automator</artifactId>
 
-  <version>1.6.0</version>
+  <version>1.7.0</version>
   <!-- Change the banner.txt version -->
   <!-- 1.5 Change OperateClient / TaskList Library -->
+  <!-- 1.6 Increase option multithreading-->
+  <!-- 1.7 add logs -->
 
   <properties>
     <java.version>17</java.version>

diff --git a/src/main/java/org/camunda/automator/bpmnengine/camunda8/BpmnEngineCamunda8.java b/src/main/java/org/camunda/automator/bpmnengine/camunda8/BpmnEngineCamunda8.java
@@ -412,6 +412,12 @@ public RegisteredTask registerServiceTask(String workerId,
     }
     RegisteredTask registeredTask = new RegisteredTask();
 
+    logger.info("Create worker[{}] Topic[{}] StreamEnabled[{}] LockTime[{}] WorkerExecutionThreads[{}] MaxJobsActive[{}]", // label
+        workerId,topic,streamEnabled,lockTime,
+        serverDefinition.workerExecutionThreads,
+    serverDefinition.workerMaxJobsActive);
+
+
     JobWorkerBuilderStep1.JobWorkerBuilderStep3 step3 = zeebeClient.newWorker()
         .jobType(topic)
         .handler((JobHandler) jobHandler)
@@ -891,7 +897,9 @@ else if (BpmnEngineList.CamundaEngine.CAMUNDA_8.equals(this.typeCamundaEngine))
       analysis.append("] ");
       if (serverDefinition.workerMaxJobsActive == -1) {
         serverDefinition.workerMaxJobsActive = serverDefinition.workerExecutionThreads;
-        analysis.append("No workerMaxJobsActive defined, align to the number of threads, ");
+        analysis.append("No workerMaxJobsActive defined, align to ExecutionThread[");
+        analysis.append(serverDefinition.workerExecutionThreads);
+        analysis.append("]");
       }
       if (serverDefinition.workerExecutionThreads > serverDefinition.workerMaxJobsActive) {
         logger.error(

diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml
@@ -44,7 +44,7 @@ automator:
     - type: "camunda7"
       name: "camunda7Emeraud"
       url: "http://localhost:8080/engine-rest"
-      workerMaxJobsActive: 20
+      workerMaxJobsActive: 1
 
     - type: "camunda8"
       description: "Simple authentication"
@@ -56,8 +56,9 @@ automator:
       taskListUserName: "demo"
       taskListUserPassword: "demo"
       taskListUrl: "http://localhost:8082"
-      workerExecutionThreads: 10
-      workerMaxJobsActive: 10
+      workerExecutionThreads: 200
+      # -1 means : align the jobsActive to the workerExecutionThreads
+      workerMaxJobsActive: -1
 
     - type: "camunda8"
       name: "Camunda8Lazuli"
@@ -82,21 +83,24 @@ automator:
       taskListUrl: "http://localhost:8082"
       taskListKeycloakUrl: "http://localhost:18080/auth/realms/camunda-platform"
 
-      workerExecutionThreads: 10
-      workerMaxJobsActive: 10
+      workerExecutionThreads: 200
+      # -1 means : align the jobsActive to the workerExecutionThreads
+      workerMaxJobsActive: -1
 
     - type: "camunda8"
       name: "Camunda8ZeebeOnly"
       zeebeGatewayAddress: "127.0.0.1:26500"
       zeebePlainText: true
-      workerExecutionThreads: 10
-      workerMaxJobsActive: 10
+      workerExecutionThreads: 200
+      # -1 means : align the jobsActive to the workerExecutionThreads
+      workerMaxJobsActive: -1
 
 
     - type: "camunda8saas"
       name: "Camunda8Grena"
-      workerExecutionThreads: 10
-      workerMaxJobsActive: 10
+      workerExecutionThreads: 200
+      # -1 means : align the jobsActive to the workerExecutionThreads
+      workerMaxJobsActive: -1
 
       region: "jfk-1"
       clusterId: "b16d70cb-b654-4d76-a3a4-d4e438e4447c"
@@ -119,7 +123,7 @@ automator:
     camunda7:
       name: "Camunda7Granit"
       url: "http://localhost:8080/engine-rest"
-      workerMaxJobsActive: 20
+      workerMaxJobsActive: 1
 
     camunda8:
       name: "Camunda8Calcair"
@@ -131,12 +135,14 @@ automator:
       taskListUserName: "demo"
       taskListUserPassword: "demo"
       workerExecutionThreads: 200
-      workerMaxJobsActive: 200
+      # -1 means : align the jobsActive to the workerExecutionThreads
+      workerMaxJobsActive: -1
 
     camunda8Saas:
       name: "Camunda8Marbble"
-      workerExecutionThreads: 10
-      workerMaxJobsActive: 10
+      workerExecutionThreads: 200
+      # -1 means : align the jobsActive to the workerExecutionThreads
+      workerMaxJobsActive: -1
 
       operateUserName: "demo"
       operateUserPassword: "demo"

diff --git a/src/main/resources/banner.txt b/src/main/resources/banner.txt
@@ -5,4 +5,4 @@ __________                                                                   __
  |____|     |__|   \____/ \___  >___  >____  >____  >         (____  /____/ |__|  \____/|__|_|  (____  /__|  \____/|__|
                               \/    \/     \/     \/               \/                         \/     \/
 
-                                                                                                                (v1.6.0)
+                                                                                                                (v1.7.0)