This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch fix/CAMEL-23974 in repository https://gitbox.apache.org/repos/asf/camel.git
commit 77c662160a392e1c95bed91d96c5fb2347cc5d8d Author: Claus Ibsen <[email protected]> AuthorDate: Thu Jul 9 13:08:55 2026 +0200 CAMEL-23974: Pass OAuth credentials from ZeebeComponent to ZeebeService Co-Authored-By: Claude Opus 4.6 <[email protected]> Signed-off-by: Claus Ibsen <[email protected]> --- .../main/java/org/apache/camel/component/zeebe/ZeebeComponent.java | 2 +- .../org/apache/camel/component/zeebe/internal/ZeebeService.java | 7 +++++++ 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeComponent.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeComponent.java index 3aea39c0d268..473d6edb1d0a 100644 --- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeComponent.java +++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeComponent.java @@ -118,7 +118,7 @@ public class ZeebeComponent extends DefaultComponent { super.doStart(); if (zeebeService == null) { - zeebeService = new ZeebeService(gatewayHost, gatewayPort); + zeebeService = new ZeebeService(gatewayHost, gatewayPort, clientId, clientSecret, oAuthAPI); zeebeService.doStart(); } } diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/internal/ZeebeService.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/internal/ZeebeService.java index 2a128bb336a7..7af75c65c535 100644 --- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/internal/ZeebeService.java +++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/internal/ZeebeService.java @@ -62,8 +62,15 @@ public class ZeebeService { private String oAuthAPI; public ZeebeService(String gatewayHost, int gatewayPort) { + this(gatewayHost, gatewayPort, null, null, null); + } + + public ZeebeService(String gatewayHost, int gatewayPort, String clientId, String clientSecret, String oAuthAPI) { this.gatewayHost = gatewayHost; this.gatewayPort = gatewayPort; + this.clientId = clientId; + this.clientSecret = clientSecret; + this.oAuthAPI = oAuthAPI; objectMapper = new ObjectMapper(); }
