This is an automated email from the ASF dual-hosted git repository. jiriondrusek pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 8b609decbd71aefd7eec8c6a39218e8e2c8f651d Author: James Netherton <[email protected]> AuthorDate: Fri Jan 2 13:25:50 2026 +0000 Align kubernetes-cluster-service extension config with latest Camel changes --- .../KubernetesClusterServiceConfigEnabledWithoutDefaultsTest.java | 4 ++-- .../KubernetesClusterServiceConfigEnabledWithoutRebalancingTest.java | 4 ++-- .../kubernetes/cluster/KubernetesClusterServiceRecorder.java | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutDefaultsTest.java b/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutDefaultsTest.java index 166711e146..6633420a73 100644 --- a/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutDefaultsTest.java +++ b/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutDefaultsTest.java @@ -90,8 +90,8 @@ public class KubernetesClusterServiceConfigEnabledWithoutDefaultsTest { assertEquals("kcs-id", kcs.getId()); assertEquals("kcs-master-url", kcs.getMasterUrl()); - assertEquals(5033, kcs.getConnectionTimeoutMillis()); - assertEquals("kcs-namespace", kcs.getKubernetesNamespace()); + assertEquals(5033, kcs.getConnectionTimeout()); + assertEquals("kcs-namespace", kcs.getNamespace()); assertEquals("kcs-pod-name", kcs.getPodName()); assertEquals(1.5034, kcs.getJitterFactor()); assertEquals(5036, kcs.getLeaseDurationMillis()); diff --git a/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutRebalancingTest.java b/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutRebalancingTest.java index d1394b87b5..5eccace22c 100644 --- a/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutRebalancingTest.java +++ b/extensions/kubernetes-cluster-service/deployment/src/test/java/org/apache/camel/quarkus/component/kubernetes/cluster/deployment/KubernetesClusterServiceConfigEnabledWithoutRebalancingTest.java @@ -78,8 +78,8 @@ public class KubernetesClusterServiceConfigEnabledWithoutRebalancingTest { assertNull(kcs.getId()); assertNull(kcs.getMasterUrl()); - assertNull(kcs.getConnectionTimeoutMillis()); - assertNull(kcs.getKubernetesNamespace()); + assertNull(kcs.getConnectionTimeout()); + assertNull(kcs.getNamespace()); assertNull(kcs.getPodName()); assertEquals(1.2, kcs.getJitterFactor()); assertEquals(15000L, kcs.getLeaseDurationMillis()); diff --git a/extensions/kubernetes-cluster-service/runtime/src/main/java/org/apache/camel/quarkus/component/kubernetes/cluster/KubernetesClusterServiceRecorder.java b/extensions/kubernetes-cluster-service/runtime/src/main/java/org/apache/camel/quarkus/component/kubernetes/cluster/KubernetesClusterServiceRecorder.java index 552bc748b5..4d314e5cf5 100644 --- a/extensions/kubernetes-cluster-service/runtime/src/main/java/org/apache/camel/quarkus/component/kubernetes/cluster/KubernetesClusterServiceRecorder.java +++ b/extensions/kubernetes-cluster-service/runtime/src/main/java/org/apache/camel/quarkus/component/kubernetes/cluster/KubernetesClusterServiceRecorder.java @@ -46,8 +46,8 @@ public class KubernetesClusterServiceRecorder { config.id().ifPresent(clusterService::setId); config.masterUrl().ifPresent(clusterService::setMasterUrl); - config.connectionTimeoutMillis().ifPresent(clusterService::setConnectionTimeoutMillis); - config.namespace().ifPresent(clusterService::setKubernetesNamespace); + config.connectionTimeoutMillis().ifPresent(clusterService::setConnectionTimeout); + config.namespace().ifPresent(clusterService::setNamespace); config.podName().ifPresent(clusterService::setPodName); config.jitterFactor().ifPresent(clusterService::setJitterFactor); config.leaseDurationMillis().ifPresent(clusterService::setLeaseDurationMillis);
