This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 4ca7aad39f5 CAMEL-19645: producer health check is default disabled.
4ca7aad39f5 is described below
commit 4ca7aad39f572dff369f489be56cec07a6630240
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Jul 28 21:26:33 2023 +0200
CAMEL-19645: producer health check is default disabled.
---
.../SecretsManagerProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../SecretsManagerProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../aws2/athena/Athena2ProducerHealthCheckCustomProducerTest.java | 6 ++++--
.../aws2/athena/Athena2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../aws2/athena/Athena2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/ddb/Ddb2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/ddb/Ddb2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckIT.java | 6 ++++--
.../aws2/ec2/AWS2EC2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../aws2/ec2/AWS2EC2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/ecs/ECS2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/ecs/ECS2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/eks/EKS2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/eks/EKS2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../eventbridge/EventbridgeProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../eventbridge/EventbridgeProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/iam/IAM2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/iam/IAM2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../aws2/kinesis/Kinesis2ConsumerHealthCheckProfileCredsIT.java | 6 ++++--
.../aws2/kinesis/Kinesis2ConsumerHealthCheckStaticCredsIT.java | 6 ++++--
.../aws2/kinesis/Kinesis2ConsumerHealthCustomClientIT.java | 6 ++++--
.../aws2/lambda/Lambda2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../aws2/lambda/Lambda2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/mq/MQ2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/mq/MQ2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/msk/MSK2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/msk/MSK2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/s3/AWS2S3ConsumerHealthCheckProfileCredsIT.java | 6 ++++--
.../component/aws2/ses/Ses2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/ses/Ses2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../component/aws2/sns/Sns2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../component/aws2/sns/Sns2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
.../translate/Translate2ProducerHealthCheckProfileCredsTest.java | 6 ++++--
.../translate/Translate2ProducerHealthCheckStaticCredsTest.java | 6 ++++--
34 files changed, 136 insertions(+), 68 deletions(-)
diff --git
a/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckProfileCredsTest.java
index ba5b9e1b21a..59b74661a98 100644
---
a/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class
SecretsManagerProducerHealthCheckProfileCredsTest extends CamelTest
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckStaticCredsTest.java
index 5ce45ece47d..56afa81243b 100644
---
a/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws-secrets-manager/src/test/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class SecretsManagerProducerHealthCheckStaticCredsTest
extends CamelTestS
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckCustomProducerTest.java
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckCustomProducerTest.java
index c50a5df6368..5736a68f9e7 100644
---
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckCustomProducerTest.java
+++
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckCustomProducerTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -51,8 +52,9 @@ public class Athena2ProducerHealthCheckCustomProducerTest
extends CamelTestSuppo
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckProfileCredsTest.java
index 4345ee780eb..b6e579439a4 100644
---
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Athena2ProducerHealthCheckProfileCredsTest
extends CamelTestSupport
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckStaticCredsTest.java
index d7e073d79e9..6bbd1266cc3 100644
---
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Athena2ProducerHealthCheckStaticCredsTest
extends CamelTestSupport
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckProfileCredsTest.java
index 5e4d36efad2..8c45063f175 100644
---
a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Ddb2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckStaticCredsTest.java
index 10e5c425a98..456322a0843 100644
---
a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddb/Ddb2ProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Ddb2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckIT.java
b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckIT.java
index 60c6a681ee7..174f0b31b42 100644
---
a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckIT.java
+++
b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckIT.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.infra.aws.common.services.AWSService;
import org.apache.camel.test.infra.aws2.services.AWSServiceFactory;
@@ -54,8 +55,9 @@ public class Ddb2StreamConsumerHealthCheckIT extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckProfileCredsTest.java
index 4acca47c906..083a5629e93 100644
---
a/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckProfileCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class AWS2EC2ProducerHealthCheckProfileCredsTest
extends CamelTestSupport
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckStaticCredsTest.java
index 93a46036038..747df57a726 100644
---
a/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-ec2/src/test/java/org/apache/camel/component/aws2/ec2/AWS2EC2ProducerHealthCheckStaticCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class AWS2EC2ProducerHealthCheckStaticCredsTest
extends CamelTestSupport
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckProfileCredsTest.java
index 991a6019703..f066b30cc35 100644
---
a/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -54,8 +55,9 @@ public class ECS2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckStaticCredsTest.java
index 213e3df0fac..94617d3877b 100644
---
a/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -54,8 +55,9 @@ public class ECS2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckProfileCredsTest.java
index a2dd891f8df..eb9255bf516 100644
---
a/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class EKS2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckStaticCredsTest.java
index 54548160aae..f69204a4c48 100644
---
a/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class EKS2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckProfileCredsTest.java
index bb3d2397496..5fbf6948495 100644
---
a/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class EventbridgeProducerHealthCheckProfileCredsTest
extends CamelTestSup
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckStaticCredsTest.java
index 40158593689..b94cff3278a 100644
---
a/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/EventbridgeProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class EventbridgeProducerHealthCheckStaticCredsTest
extends CamelTestSupp
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckProfileCredsTest.java
index 104f572f44b..8a7b447674c 100644
---
a/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckProfileCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class IAM2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckStaticCredsTest.java
index 23872e51531..514c682967a 100644
---
a/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-iam/src/test/java/org/apache/camel/component/aws2/iam/IAM2ProducerHealthCheckStaticCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class IAM2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckProfileCredsIT.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckProfileCredsIT.java
index 0059eece920..32795c37d8b 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckProfileCredsIT.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckProfileCredsIT.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.infra.aws.common.services.AWSService;
import org.apache.camel.test.infra.aws2.clients.AWSSDKClientUtils;
@@ -59,8 +60,9 @@ public class Kinesis2ConsumerHealthCheckProfileCredsIT
extends CamelTestSupport
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckStaticCredsIT.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckStaticCredsIT.java
index e49164670e7..cba4484e710 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckStaticCredsIT.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCheckStaticCredsIT.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.infra.aws.common.services.AWSService;
import org.apache.camel.test.infra.aws2.clients.AWSSDKClientUtils;
@@ -60,8 +61,9 @@ public class Kinesis2ConsumerHealthCheckStaticCredsIT extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCustomClientIT.java
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCustomClientIT.java
index fbcb5be76d9..cbb743abf96 100644
---
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCustomClientIT.java
+++
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/Kinesis2ConsumerHealthCustomClientIT.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.infra.aws.common.services.AWSService;
import org.apache.camel.test.infra.aws2.clients.AWSSDKClientUtils;
@@ -67,8 +68,9 @@ public class Kinesis2ConsumerHealthCustomClientIT extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckProfileCredsTest.java
index a7a08e4ba9e..fef1da99d72 100644
---
a/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Lambda2ProducerHealthCheckProfileCredsTest
extends CamelTestSupport
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckStaticCredsTest.java
index 195c5d5fef2..e57f693b8f6 100644
---
a/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-lambda/src/test/java/org/apache/camel/component/aws2/lambda/Lambda2ProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Lambda2ProducerHealthCheckStaticCredsTest
extends CamelTestSupport
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckProfileCredsTest.java
index 491449df591..20019847470 100644
---
a/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class MQ2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckStaticCredsTest.java
index ac8b3c77c8b..e0cf3f57bf1 100644
---
a/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQ2ProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class MQ2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckProfileCredsTest.java
index d7b652f98d3..fb2192d0ffe 100644
---
a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckProfileCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class MSK2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckStaticCredsTest.java
index 9fecf259f37..52491a413aa 100644
---
a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSK2ProducerHealthCheckStaticCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class MSK2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheckProfileCredsIT.java
b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheckProfileCredsIT.java
index aa2deb5e24c..eb394b956f8 100644
---
a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheckProfileCredsIT.java
+++
b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheckProfileCredsIT.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.infra.aws.common.services.AWSService;
import org.apache.camel.test.infra.aws2.clients.AWSSDKClientUtils;
@@ -59,8 +60,9 @@ public class AWS2S3ConsumerHealthCheckProfileCredsIT extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckProfileCredsTest.java
index bc783f675c9..58cfe1644d2 100644
---
a/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Ses2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckStaticCredsTest.java
index 16a9c8b6180..4b5e5cf17e6 100644
---
a/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-ses/src/test/java/org/apache/camel/component/aws2/ses/Ses2ProducerHealthCheckStaticCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class Ses2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckProfileCredsTest.java
index 15b08750c32..ac096263e97 100644
---
a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckProfileCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class Sns2ProducerHealthCheckProfileCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckStaticCredsTest.java
index 12ecb451868..d727b6abc90 100644
---
a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/Sns2ProducerHealthCheckStaticCredsTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -49,8 +50,9 @@ public class Sns2ProducerHealthCheckStaticCredsTest extends
CamelTestSupport {
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckProfileCredsTest.java
b/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckProfileCredsTest.java
index ffeb4f4ef66..5b770b4f2f0 100644
---
a/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckProfileCredsTest.java
+++
b/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckProfileCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Translate2ProducerHealthCheckProfileCredsTest
extends CamelTestSupp
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
diff --git
a/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckStaticCredsTest.java
b/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckStaticCredsTest.java
index b6b77cbe667..beb891a0bf3 100644
---
a/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckStaticCredsTest.java
+++
b/components/camel-aws/camel-aws2-translate/src/test/java/org/apache/camel/component/aws2/translate/Translate2ProducerHealthCheckStaticCredsTest.java
@@ -25,6 +25,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckHelper;
import org.apache.camel.health.HealthCheckRegistry;
+import org.apache.camel.health.HealthCheckRepository;
import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Assertions;
@@ -50,8 +51,9 @@ public class Translate2ProducerHealthCheckStaticCredsTest
extends CamelTestSuppo
registry.register(hc);
hc = registry.resolveById("consumers");
registry.register(hc);
- hc = registry.resolveById("producers");
- registry.register(hc);
+ HealthCheckRepository hcr = (HealthCheckRepository)
registry.resolveById("producers");
+ hcr.setEnabled(true);
+ registry.register(hcr);
context.getCamelContextExtension().addContextPlugin(HealthCheckRegistry.class,
registry);
return context;
