Avoid subscription for user tasks if the deployed processes does not …

…contain any
camunda-community-hub · Feb 27, 2024 · ace78d5 · ace78d5
1 parent b7fe56b
commit ace78d5
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/spring-boot/src/main/java/io/vanillabp/camunda8/wiring/Camunda8TaskWiring.java b/spring-boot/src/main/java/io/vanillabp/camunda8/wiring/Camunda8TaskWiring.java
@@ -99,14 +99,16 @@ public void accept(
  public void openWorkers() {
 
  // fetch all usertasks spawned
- workers.add(
- client
- .newWorker()
- .jobType("io.camunda.zeebe:userTask")
- .handler(userTaskHandler)
- .timeout(Integer.MAX_VALUE) // user-tasks are not fetched more than once
- .name(workerId)
- .tenantIds(userTaskTenantIds.stream().toList()));
+ if(!userTaskTenantIds.isEmpty()){
+ workers.add(
+ client
+ .newWorker()
+ .jobType("io.camunda.zeebe:userTask")
+ .handler(userTaskHandler)
+ .timeout(Integer.MAX_VALUE) // user-tasks are not fetched more than once
+ .name(workerId)
+ .tenantIds(userTaskTenantIds.stream().toList()));
+ }
 
  workers
  .forEach(JobWorkerBuilderStep3::open);