Support multi-tenancy per worker (#614)

* formatter

* formatter

* formatter

* introduced configurable tenant ids for workers

* remove adding default tenant ids to job worker configuration

* update workflow to verify format

* added a test to prove a zeebe worker value picks up the tenant ids

Author: jonathanlukas

.github/workflows/mvn-build.yml

@@ -20,4 +20,4 @@ jobs:
           java-version: '21'
           distribution: 'adopt'
       - name: Build with Maven
-        run: mvn --batch-mode --update-snapshots package
+        run: mvn verify -PcheckFormat -B

CONTRIBUTING.md

@@ -27,7 +27,7 @@ If you have additional information that can help us understand the behaviour of
 
 If no issue already exists for the bug, please create a new one.
 
-When creating a bug report, please fill out the template. What really helps us are the steps for us to be able reproduce the problem in front of us. 
+When creating a bug report, please fill out the template. What really helps us are the steps for us to be able reproduce the problem in front of us.
 
 To generate these, start from nothing, and document the steps required to set up a project that shows the bug. If you create such a project as a new GitHub repo, you will have a Minimal Reproducible Example. We can then check out that project and see the bug in front of us immediately. This will increase the speed that we can address the issue. It will also help you isolate the actual issue, and sometimes to fix it.
 
@@ -45,9 +45,9 @@ If you have additional information that can help us understand the behaviour you
 
 If no issue already exists for the feature request, please create a new one.
 
-When creating a feature request, please fill out the template. What really helps us are both the motivation for the feature (what is your use-case and what you want to achieve), as well as what you would like the feature to be. Sometimes there is an existing way to accomplish what you want, and we may be able to recommend that. 
+When creating a feature request, please fill out the template. What really helps us are both the motivation for the feature (what is your use-case and what you want to achieve), as well as what you would like the feature to be. Sometimes there is an existing way to accomplish what you want, and we may be able to recommend that.
 
-If there is no existing way to do it, then understanding the use-case that motivates the feature request helps us to triage it, and also to design the feature implementation.  
+If there is no existing way to do it, then understanding the use-case that motivates the feature request helps us to triage it, and also to design the feature implementation.
 
 ## Fix to documentation
 
@@ -57,7 +57,7 @@ Please read the [Code Style Guidelines](#code-style-guidelines) and [Commit Mess
 
 ## Code contribution for an existing issue
 
-Maybe you patch an existing bug, or implement a requested feature for yourself - without waiting for us to get to it. You can contribute that to the codebase as a pull request. This way, you don't end up maintaining a separate fork. 
+Maybe you patch an existing bug, or implement a requested feature for yourself - without waiting for us to get to it. You can contribute that to the codebase as a pull request. This way, you don't end up maintaining a separate fork.
 
 See the section [Running a development version](#running-a-development-version) for instructions on how to use your fork locally to test your changes.
 

README.md

@@ -5,7 +5,7 @@
 [![Maven Central](https://maven-badges.herokuapp.com/maven-central/io.camunda/spring-zeebe/badge.svg)](https://maven-badges.herokuapp.com/maven-central/io.camunda/spring-zeebe)
 [![Project Stats](https://www.openhub.net/p/spring-zeebe/widgets/project_thin_badge.gif)](https://www.openhub.net/p/spring-zeebe)
 
-Spring Zeebe will slowly evolve towards Camunda Spring SDK. 
+Spring Zeebe will slowly evolve towards Camunda Spring SDK.
 
 This project allows you to leverage Zeebe, Operate, Optimize, Tasklist, Console, and Modeler within your Spring or Spring Boot environment.
 
@@ -35,7 +35,7 @@ This project allows you to leverage Zeebe, Operate, Optimize, Tasklist, Console,
 
 ## Exciting news: Evolution of Spring-Zeebe into a Camunda Spring SDK
 
-This SDK will support all Camunda Products (Zeebe, Operate, Tasklist, etc) in a unified way. 
+This SDK will support all Camunda Products (Zeebe, Operate, Tasklist, etc) in a unified way.
 
 What to expect in the coming months:
 

camunda-sdk-java/java-client-operate/README.md

@@ -5,9 +5,9 @@
 This client is part of the Spring Zeebe project. If you intend to use it outside of this project, you can add a dependency to io.camunda.spring:java-client-operate
 ```xml
 <dependency>
-	<groupId>io.camunda.spring</groupId>
-	<artifactId>java-client-operate</artifactId>
-	<version>8.3.4</version>
+  <groupId>io.camunda.spring</groupId>
+  <artifactId>java-client-operate</artifactId>
+  <version>8.3.4</version>
 </dependency>
 ```
 

camunda-sdk-java/java-client-operate/src/main/java/io/camunda/operate/CamundaOperateClient.java

@@ -6,7 +6,6 @@
 import io.camunda.operate.search.SearchQuery;
 import io.camunda.zeebe.model.bpmn.Bpmn;
 import io.camunda.zeebe.model.bpmn.BpmnModelInstance;
-
 import java.io.ByteArrayInputStream;
 import java.io.InputStream;
 import java.util.List;
@@ -26,9 +25,8 @@ public ProcessDefinition getProcessDefinition(Long key) throws OperateException
   public BpmnModelInstance getProcessDefinitionModel(Long key) throws OperateException {
     String xml = getProcessDefinitionXml(key);
     try {
-        InputStream processInputStream = new ByteArrayInputStream(
-          xml.getBytes());
-        return Bpmn.readModelFromStream(processInputStream);
+      InputStream processInputStream = new ByteArrayInputStream(xml.getBytes());
+      return Bpmn.readModelFromStream(processInputStream);
     } catch (Exception e) {
       throw new OperateException(e);
     }
@@ -38,68 +36,103 @@ public String getProcessDefinitionXml(Long key) throws OperateException {
     return httpClient.getXml(ProcessDefinition.class, key);
   }
 
-  public List<ProcessDefinition> searchProcessDefinitions(SearchQuery query) throws OperateException {
+  public List<ProcessDefinition> searchProcessDefinitions(SearchQuery query)
+      throws OperateException {
     return searchProcessDefinitionResults(query).getItems();
   }
 
-  public SearchResult<ProcessDefinition> searchProcessDefinitionResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, ProcessDefinition.class, SearchResultTypeToken.searchResultProcessDefinition, query);
+  public SearchResult<ProcessDefinition> searchProcessDefinitionResults(SearchQuery query)
+      throws OperateException {
+    return httpClient.post(
+        SearchResult.class,
+        ProcessDefinition.class,
+        SearchResultTypeToken.searchResultProcessDefinition,
+        query);
   }
 
-  public List<DecisionDefinition> searchDecisionDefinitions(SearchQuery query) throws OperateException {
+  public List<DecisionDefinition> searchDecisionDefinitions(SearchQuery query)
+      throws OperateException {
     return searchDecisionDefinitionResults(query).getItems();
   }
 
-  public SearchResult<DecisionDefinition> searchDecisionDefinitionResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, DecisionDefinition.class, SearchResultTypeToken.searchResultDecisionDefinition, query);
+  public SearchResult<DecisionDefinition> searchDecisionDefinitionResults(SearchQuery query)
+      throws OperateException {
+    return httpClient.post(
+        SearchResult.class,
+        DecisionDefinition.class,
+        SearchResultTypeToken.searchResultDecisionDefinition,
+        query);
   }
 
   public List<DecisionInstance> searchDecisionInstances(SearchQuery query) throws OperateException {
     return searchDecisionInstanceResults(query).getItems();
   }
 
-  public SearchResult<DecisionInstance> searchDecisionInstanceResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, DecisionInstance.class, SearchResultTypeToken.searchResultDecisionInstance, query);
+  public SearchResult<DecisionInstance> searchDecisionInstanceResults(SearchQuery query)
+      throws OperateException {
+    return httpClient.post(
+        SearchResult.class,
+        DecisionInstance.class,
+        SearchResultTypeToken.searchResultDecisionInstance,
+        query);
   }
 
   public List<FlowNodeInstance> searchFlowNodeInstances(SearchQuery query) throws OperateException {
     return searchFlowNodeInstanceResults(query).getItems();
   }
 
-  public SearchResult<FlowNodeInstance> searchFlowNodeInstanceResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, FlowNodeInstance.class, SearchResultTypeToken.searchResultFlowNodeInstance, query);
+  public SearchResult<FlowNodeInstance> searchFlowNodeInstanceResults(SearchQuery query)
+      throws OperateException {
+    return httpClient.post(
+        SearchResult.class,
+        FlowNodeInstance.class,
+        SearchResultTypeToken.searchResultFlowNodeInstance,
+        query);
   }
 
   public List<Variable> searchVariables(SearchQuery query) throws OperateException {
     return searchVariableResults(query).getItems();
   }
 
   public SearchResult<Variable> searchVariableResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, Variable.class, SearchResultTypeToken.searchResultVariable, query);
+    return httpClient.post(
+        SearchResult.class, Variable.class, SearchResultTypeToken.searchResultVariable, query);
   }
 
   public List<ProcessInstance> searchProcessInstances(SearchQuery query) throws OperateException {
     return searchProcessInstanceResults(query).getItems();
   }
 
-  public SearchResult<ProcessInstance> searchProcessInstanceResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, ProcessInstance.class, SearchResultTypeToken.searchResultProcessInstance, query);
+  public SearchResult<ProcessInstance> searchProcessInstanceResults(SearchQuery query)
+      throws OperateException {
+    return httpClient.post(
+        SearchResult.class,
+        ProcessInstance.class,
+        SearchResultTypeToken.searchResultProcessInstance,
+        query);
   }
 
-  public List<DecisionRequirements> searchDecisionRequirements(SearchQuery query) throws OperateException {
+  public List<DecisionRequirements> searchDecisionRequirements(SearchQuery query)
+      throws OperateException {
     return searchDecisionRequirementsResults(query).getItems();
   }
 
-  public SearchResult<DecisionRequirements> searchDecisionRequirementsResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, DecisionRequirements.class, SearchResultTypeToken.searchResultDecisionRequirements, query);
+  public SearchResult<DecisionRequirements> searchDecisionRequirementsResults(SearchQuery query)
+      throws OperateException {
+    return httpClient.post(
+        SearchResult.class,
+        DecisionRequirements.class,
+        SearchResultTypeToken.searchResultDecisionRequirements,
+        query);
   }
 
   public List<Incident> searchIncidents(SearchQuery query) throws OperateException {
     return searchIncidentResults(query).getItems();
   }
 
   public SearchResult<Incident> searchIncidentResults(SearchQuery query) throws OperateException {
-    return httpClient.post(SearchResult.class, Incident.class, SearchResultTypeToken.searchResultIncident, query);
+    return httpClient.post(
+        SearchResult.class, Incident.class, SearchResultTypeToken.searchResultIncident, query);
   }
 
   public ProcessInstance getProcessInstance(Long key) throws OperateException {
@@ -111,7 +144,8 @@ public ChangeStatus deleteProcessInstance(Long key) throws OperateException {
   }
 
   public List<FlowNodeStatistics> getFlowNodeStatistics(Long key) throws OperateException {
-    return httpClient.get(List.class, FlowNodeStatistics.class, ListTypeToken.listFlowNodeStatistics, key);
+    return httpClient.get(
+        List.class, FlowNodeStatistics.class, ListTypeToken.listFlowNodeStatistics, key);
   }
 
   public List<String> getSequenceFlows(Long key) throws OperateException {

camunda-sdk-java/java-client-operate/src/main/java/io/camunda/operate/CamundaOperateClientBuilder.java

@@ -5,7 +5,6 @@
 import io.camunda.common.http.DefaultHttpClient;
 import io.camunda.common.http.HttpClient;
 import io.camunda.operate.model.*;
-
 import java.util.HashMap;
 import java.util.Map;
 
@@ -16,7 +15,6 @@ public class CamundaOperateClientBuilder {
   private String operateUrl;
   private HttpClient httpClient;
 
-
   public CamundaOperateClientBuilder authentication(Authentication authentication) {
     this.authentication = authentication;
     return this;
@@ -42,12 +40,21 @@ public CamundaOperateClientBuilder setup() {
     map.put(DecisionDefinition.class, "/decision-definitions");
     map.put(DecisionRequirements.class, "/drd");
     map.put(DecisionInstance.class, "/decision-instances");
-    map.put(SearchResultTypeToken.searchResultProcessDefinition.getClass(), "/process-definitions/search");
-    map.put(SearchResultTypeToken.searchResultDecisionDefinition.getClass(), "/decision-definitions/search");
-    map.put(SearchResultTypeToken.searchResultDecisionInstance.getClass(), "/decision-instances/search");
-    map.put(SearchResultTypeToken.searchResultFlowNodeInstance.getClass(), "/flownode-instances/search");
+    map.put(
+        SearchResultTypeToken.searchResultProcessDefinition.getClass(),
+        "/process-definitions/search");
+    map.put(
+        SearchResultTypeToken.searchResultDecisionDefinition.getClass(),
+        "/decision-definitions/search");
+    map.put(
+        SearchResultTypeToken.searchResultDecisionInstance.getClass(),
+        "/decision-instances/search");
+    map.put(
+        SearchResultTypeToken.searchResultFlowNodeInstance.getClass(),
+        "/flownode-instances/search");
     map.put(SearchResultTypeToken.searchResultVariable.getClass(), "/variables/search");
-    map.put(SearchResultTypeToken.searchResultProcessInstance.getClass(), "/process-instances/search");
+    map.put(
+        SearchResultTypeToken.searchResultProcessInstance.getClass(), "/process-instances/search");
     map.put(SearchResultTypeToken.searchResultDecisionRequirements.getClass(), "/drd/search");
     map.put(SearchResultTypeToken.searchResultIncident.getClass(), "/incidents/search");
     httpClient.loadMap(Product.OPERATE, map);
@@ -56,7 +63,7 @@ public CamundaOperateClientBuilder setup() {
 
   private String formatUrl(String url) {
     if (url.endsWith("/")) {
-      return url.substring(0, url.length()-1);
+      return url.substring(0, url.length() - 1);
     }
     return url;
   }

camunda-sdk-java/java-client-operate/src/main/java/io/camunda/operate/exception/OperateException.java

@@ -1,21 +1,21 @@
 package io.camunda.operate.exception;
 
 public class OperateException extends Exception {
-    private static final long serialVersionUID = -7593616210087047797L;
+  private static final long serialVersionUID = -7593616210087047797L;
 
-    public OperateException() {
-        super();
-    }
+  public OperateException() {
+    super();
+  }
 
-    public OperateException(Exception e) {
-        super(e);
-    }
+  public OperateException(Exception e) {
+    super(e);
+  }
 
-    public OperateException(String message) {
-        super(message);
-    }
+  public OperateException(String message) {
+    super(message);
+  }
 
-    public OperateException(String message, Exception e) {
-        super(message, e);
-    }
+  public OperateException(String message, Exception e) {
+    super(message, e);
+  }
 }

camunda-sdk-java/java-client-operate/src/main/java/io/camunda/operate/model/ChangeStatus.java

@@ -20,5 +20,4 @@ public Long getDeleted() {
   public void setDeleted(Long deleted) {
     this.deleted = deleted;
   }
-
 }

camunda-sdk-java/java-client-operate/src/main/java/io/camunda/operate/model/DecisionInstanceInput.java

@@ -5,6 +5,7 @@ public class DecisionInstanceInput {
   private String id;
   private String name;
   private String value;
+
   public String getId() {
     return id;
   }

camunda-sdk-java/java-client-operate/src/main/java/io/camunda/operate/model/DecisionRequirements.java

@@ -9,6 +9,7 @@ public class DecisionRequirements {
   private Long version;
   private String resourceName;
   private String tenantId;
+
   public String getId() {
     return id;
   }