diff --git a/README.md b/README.md index 77cc3fa..8cce860 100644 --- a/README.md +++ b/README.md @@ -344,7 +344,7 @@ 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 . ```` @@ -352,15 +352,15 @@ docker build -t pierre-yves-monnet/processautomator:1.6.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 index 472e140..827979a 100644 --- a/pom.xml +++ b/pom.xml @@ -6,9 +6,11 @@ org.camunda.community.automator process-execution-automator - 1.6.0 + 1.7.0 + + 17 diff --git a/src/main/java/org/camunda/automator/bpmnengine/camunda8/BpmnEngineCamunda8.java b/src/main/java/org/camunda/automator/bpmnengine/camunda8/BpmnEngineCamunda8.java index 9404ffa..99edf2a 100644 --- 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 index 5d93760..c0a2aeb 100644 --- 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 index 48c8a12..a349ce2 100644 --- a/src/main/resources/banner.txt +++ b/src/main/resources/banner.txt @@ -5,4 +5,4 @@ __________ __ |____| |__| \____/ \___ >___ >____ >____ > (____ /____/ |__| \____/|__|_| (____ /__| \____/|__| \/ \/ \/ \/ \/ \/ \/ - (v1.6.0) + (v1.7.0)