This is an automated email from the ASF dual-hosted git repository. zbendhiba pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus-examples.git
commit 96ea8090401d791720169e176182e694ce6c0e73 Author: Lukas Lowinger <[email protected]> AuthorDate: Tue Sep 20 10:23:22 2022 +0200 Be able to change root folder of FileLock --- .../src/main/java/org/acme/master/ClusterLockProducer.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/cluster-leader-election/src/main/java/org/acme/master/ClusterLockProducer.java b/cluster-leader-election/src/main/java/org/acme/master/ClusterLockProducer.java index a9782d5..86855c6 100644 --- a/cluster-leader-election/src/main/java/org/acme/master/ClusterLockProducer.java +++ b/cluster-leader-election/src/main/java/org/acme/master/ClusterLockProducer.java @@ -25,10 +25,14 @@ import org.apache.camel.CamelContext; import org.apache.camel.cluster.CamelClusterService; import org.apache.camel.component.file.cluster.FileLockClusterService; import org.apache.camel.component.kubernetes.cluster.KubernetesClusterService; +import org.eclipse.microprofile.config.inject.ConfigProperty; @ApplicationScoped public class ClusterLockProducer { + @ConfigProperty(name = "cluster.leader.election.root.folder", defaultValue = "target/cluster") + String rootFolder; + @Produces public CamelClusterService clusterService(CamelContext camelContext) { String kubernetesNamespace = System.getenv("KUBERNETES_NAMESPACE"); @@ -38,7 +42,7 @@ public class ClusterLockProducer { return service; } else { FileLockClusterService service = new FileLockClusterService(); - service.setRoot("target/cluster"); + service.setRoot(rootFolder); service.setAcquireLockDelay(1, TimeUnit.SECONDS); service.setAcquireLockInterval(1, TimeUnit.SECONDS); return service;
