[camel-quarkus-examples] branch camel-quarkus-main updated: Be able to change root folder of FileLock

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch camel-quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus-examples.git


The following commit(s) were added to refs/heads/camel-quarkus-main by this 
push:
     new 4b5f398  Be able to change root folder of FileLock
4b5f398 is described below

commit 4b5f398a3902ce76d17423fde7411eea274f46bb
Author: Lukas Lowinger <llowi...@redhat.com>
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;