[camel] 05/08: CAMEL-18131 - camel-health - Add health checks for components that has extension for connectivity verification - ECS

[acosentino]

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 3bea1de9bdb4a814f1d3414f785e14d7341f0e8a
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Dec 19 11:28:31 2022 +0100

    CAMEL-18131 - camel-health - Add health checks for components that has 
extension for connectivity verification - ECS
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 .../aws2/ecs/ECS2ClientHealthCheckStaticCredsTest.java       | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ClientHealthCheckStaticCredsTest.java
 
b/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ClientHealthCheckStaticCredsTest.java
index 46704bbf789..5458ba9e4b9 100644
--- 
a/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ClientHealthCheckStaticCredsTest.java
+++ 
b/components/camel-aws/camel-aws2-ecs/src/test/java/org/apache/camel/component/aws2/ecs/ECS2ClientHealthCheckStaticCredsTest.java
@@ -32,7 +32,7 @@ import org.slf4j.LoggerFactory;
 import java.util.Collection;
 import java.util.concurrent.TimeUnit;
 
-import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
+import static org.awaitility.Awaitility.await;
 
 public class ECS2ClientHealthCheckStaticCredsTest extends CamelTestSupport {
 
@@ -66,7 +66,7 @@ public class ECS2ClientHealthCheckStaticCredsTest extends 
CamelTestSupport {
             @Override
             public void configure() {
                 from("direct:listClusters")
-                        
.to("aws2-eks://test?operation=listClusters&region=l&secretKey=l&accessKey=k");
+                        
.to("aws2-ecs://test?operation=listClusters&region=l&secretKey=l&accessKey=k");
             }
         };
     }
@@ -82,15 +82,15 @@ public class ECS2ClientHealthCheckStaticCredsTest extends 
CamelTestSupport {
         await().atMost(20, TimeUnit.SECONDS).untilAsserted(() -> {
             Collection<HealthCheck.Result> res2 = 
HealthCheckHelper.invokeReadiness(context);
             boolean down = res2.stream().allMatch(r -> 
r.getState().equals(HealthCheck.State.DOWN));
-            boolean containsAws2AthenaHealthCheck = res2.stream()
-                    .filter(result -> 
result.getCheck().getId().startsWith("aws2-eks-client"))
+            boolean containsAws2EcsHealthCheck = res2.stream()
+                    .filter(result -> 
result.getCheck().getId().startsWith("aws2-ecs-client"))
                     .findAny()
                     .isPresent();
             boolean hasRegionMessage = res2.stream()
                     .anyMatch(r -> r.getMessage().stream().anyMatch(msg -> 
msg.contains("region")));
             Assertions.assertTrue(down, "liveness check");
-            Assertions.assertTrue(containsAws2AthenaHealthCheck, "aws2-eks 
check");
-            Assertions.assertTrue(hasRegionMessage, "aws2-eks check error 
message");
+            Assertions.assertTrue(containsAws2EcsHealthCheck, "aws2-ecs 
check");
+            Assertions.assertTrue(hasRegionMessage, "aws2-ecs check error 
message");
         });
 
     }