[camel-quarkus] branch main updated: Add Camel service inclusion pattern for periodic-task

[jamesnetherton]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 32823c27e9 Add Camel service inclusion pattern for periodic-task
32823c27e9 is described below

commit 32823c27e908cb56f2dc7834a17c2fc717a7ba8b
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Mon Sep 25 13:35:18 2023 +0100

    Add Camel service inclusion pattern for periodic-task
    
    Fixes #5343
---
 .../camel/quarkus/core/deployment/CamelProcessor.java       |  3 ++-
 .../aws/secrets/manager/it/AwsSecretsManagerResource.java   | 13 +++++++++++++
 .../aws/secrets/manager/it/AwsSecretsManagerTest.java       |  7 +++++++
 3 files changed, 22 insertions(+), 1 deletion(-)

diff --git 
a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java
 
b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java
index 38de8686c4..e354d2a428 100644
--- 
a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java
+++ 
b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelProcessor.java
@@ -173,7 +173,8 @@ class CamelProcessor {
                 "META-INF/services/org/apache/camel/send-dynamic/*",
                 "META-INF/services/org/apache/camel/urifactory/*",
                 "META-INF/services/org/apache/camel/properties-function/*",
-                "META-INF/services/org/apache/camel/health-check/*"));
+                "META-INF/services/org/apache/camel/health-check/*",
+                "META-INF/services/org/apache/camel/periodic-task/*"));
     }
 
     @BuildStep
diff --git 
a/integration-tests-jvm/aws-secrets-manager/src/main/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerResource.java
 
b/integration-tests-jvm/aws-secrets-manager/src/main/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerResource.java
index 3347c8b103..09ce162bab 100644
--- 
a/integration-tests-jvm/aws-secrets-manager/src/main/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerResource.java
+++ 
b/integration-tests-jvm/aws-secrets-manager/src/main/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerResource.java
@@ -18,11 +18,13 @@ package 
org.apache.camel.quarkus.component.aws.secrets.manager.it;
 
 import java.net.URI;
 import java.util.Map;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import jakarta.ws.rs.Consumes;
+import jakarta.ws.rs.GET;
 import jakarta.ws.rs.POST;
 import jakarta.ws.rs.Path;
 import jakarta.ws.rs.PathParam;
@@ -34,6 +36,8 @@ import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.ProducerTemplate;
 import org.apache.camel.component.aws.secretsmanager.SecretsManagerOperations;
+import org.apache.camel.spi.PeriodTaskResolver;
+import org.apache.camel.support.PluginHelper;
 import org.apache.camel.util.CollectionHelper;
 import org.jboss.logging.Logger;
 import 
software.amazon.awssdk.services.secretsmanager.model.CreateSecretResponse;
@@ -111,4 +115,13 @@ public class AwsSecretsManagerResource {
 
         return Response.created(new 
URI("https://camel.apache.org/";)).entity(result).build();
     }
+
+    @Path("/period/task/resolver/exists")
+    @GET
+    @Produces(MediaType.TEXT_PLAIN)
+    public boolean awsSecretRefreshPeriodicTaskExists() {
+        PeriodTaskResolver periodTaskResolver = 
PluginHelper.getPeriodTaskResolver(context);
+        Objects.requireNonNull(periodTaskResolver, "Expected a 
PeriodTaskResolver to be configured");
+        return periodTaskResolver.newInstance("aws-secret-refresh", 
Runnable.class).isPresent();
+    }
 }
diff --git 
a/integration-tests-jvm/aws-secrets-manager/src/test/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerTest.java
 
b/integration-tests-jvm/aws-secrets-manager/src/test/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerTest.java
index 698ecf9cd6..93a0754a47 100644
--- 
a/integration-tests-jvm/aws-secrets-manager/src/test/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerTest.java
+++ 
b/integration-tests-jvm/aws-secrets-manager/src/test/java/org/apache/camel/quarkus/component/aws/secrets/manager/it/AwsSecretsManagerTest.java
@@ -186,4 +186,11 @@ class AwsSecretsManagerTest {
         //                .body(is("true"));
     }
 
+    @Test
+    public void testAwsSecretRefreshPeriodicTaskExists() {
+        RestAssured.get("/aws-secrets-manager/period/task/resolver/exists")
+                .then()
+                .statusCode(200)
+                .body(is("true"));
+    }
 }