This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch backport/24557-to-camel-4.18.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1839f15f0dd5175a217bcc21c8ccd9dd961d13df Author: Claus Ibsen <[email protected]> AuthorDate: Thu Jul 9 13:46:17 2026 +0200 CAMEL-23974: Pass OAuth credentials from ZeebeComponent to ZeebeService Fix silent OAuth authentication failure in camel-zeebe where clientId, clientSecret, and oAuthAPI configured on ZeebeComponent were never passed to ZeebeService, making the OAuth code path unreachable dead code. Closes #24557 Co-Authored-By: Claude Opus 4.6 <[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 d208816eaeca..79daf4fd0e43 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 @@ -116,7 +116,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 5f331a8c0bf7..c1e3bb97e1b2 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 @@ -61,8 +61,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(); }
