This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 08b2db0c910c6ef3665ba266d563788481dc5ac4 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Nov 9 11:56:23 2022 +0100 CAMEL-18131 - camel-health - Add health checks for components that has extension for connectivity verification - DynamoDB Streams Signed-off-by: Andrea Cosentino <[email protected]> --- .../component/aws2/ddbstream/Ddb2StreamConsumerHealthCheck.java | 4 ++-- .../ddbstream/Ddb2StreamConsumerHealthCheckProfileCredsTest.java | 7 +++---- .../ddbstream/Ddb2StreamConsumerHealthCheckStaticCredsTest.java | 6 +++--- .../aws2/ddbstream/Ddb2StreamConsumerHealthCustomClientTest.java | 7 +++---- 4 files changed, 11 insertions(+), 13 deletions(-) diff --git a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheck.java b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheck.java index 8f5cec8e28c..6a9d727bc96 100644 --- a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheck.java +++ b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheck.java @@ -16,6 +16,8 @@ */ package org.apache.camel.component.aws2.ddbstream; +import java.util.Map; + import org.apache.camel.health.HealthCheckResultBuilder; import org.apache.camel.impl.health.AbstractHealthCheck; import org.apache.camel.util.ObjectHelper; @@ -26,8 +28,6 @@ import software.amazon.awssdk.regions.Region; import software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient; import software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClientBuilder; -import java.util.Map; - public class Ddb2StreamConsumerHealthCheck extends AbstractHealthCheck { private final Ddb2StreamConsumer ddb2StreamConsumer; diff --git a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckProfileCredsTest.java b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckProfileCredsTest.java index 36db874cff7..3d5dd9866c1 100644 --- a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckProfileCredsTest.java +++ b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckProfileCredsTest.java @@ -16,6 +16,9 @@ */ package org.apache.camel.component.aws2.ddbstream; +import java.util.Collection; +import java.util.concurrent.TimeUnit; + import org.apache.camel.CamelContext; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.health.HealthCheck; @@ -23,7 +26,6 @@ import org.apache.camel.health.HealthCheckHelper; import org.apache.camel.health.HealthCheckRegistry; 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; import org.apache.camel.test.infra.aws2.services.AWSServiceFactory; import org.apache.camel.test.junit5.CamelTestSupport; import org.junit.jupiter.api.Assertions; @@ -33,9 +35,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient; -import java.util.Collection; -import java.util.concurrent.TimeUnit; - import static org.testcontainers.shaded.org.awaitility.Awaitility.await; public class Ddb2StreamConsumerHealthCheckProfileCredsTest extends CamelTestSupport { diff --git a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckStaticCredsTest.java b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckStaticCredsTest.java index 51498cf457d..e4da968fceb 100644 --- a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckStaticCredsTest.java +++ b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCheckStaticCredsTest.java @@ -16,6 +16,9 @@ */ package org.apache.camel.component.aws2.ddbstream; +import java.util.Collection; +import java.util.concurrent.TimeUnit; + import org.apache.camel.CamelContext; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.health.HealthCheck; @@ -31,9 +34,6 @@ import org.junit.jupiter.api.extension.RegisterExtension; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.util.Collection; -import java.util.concurrent.TimeUnit; - import static org.testcontainers.shaded.org.awaitility.Awaitility.await; public class Ddb2StreamConsumerHealthCheckStaticCredsTest extends CamelTestSupport { diff --git a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCustomClientTest.java b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCustomClientTest.java index b111edef014..7a4f9b7410e 100644 --- a/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCustomClientTest.java +++ b/components/camel-aws/camel-aws2-ddb/src/test/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConsumerHealthCustomClientTest.java @@ -16,6 +16,9 @@ */ package org.apache.camel.component.aws2.ddbstream; +import java.util.Collection; +import java.util.concurrent.TimeUnit; + import org.apache.camel.CamelContext; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.health.HealthCheck; @@ -23,7 +26,6 @@ import org.apache.camel.health.HealthCheckHelper; import org.apache.camel.health.HealthCheckRegistry; 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; import org.apache.camel.test.infra.aws2.services.AWSServiceFactory; import org.apache.camel.test.junit5.CamelTestSupport; import org.junit.jupiter.api.Assertions; @@ -34,9 +36,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient; -import java.util.Collection; -import java.util.concurrent.TimeUnit; - import static org.testcontainers.shaded.org.awaitility.Awaitility.await; @DisabledIfSystemProperty(named = "ci.env.name", matches = "github.com", disabledReason = "Flaky on Apache CI")
