[camel-quarkus] branch main updated: Ensure ElasticSearch REST delete index route uses the correct URI scheme

[ja...@apache.org]

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 4589debf2c Ensure ElasticSearch REST delete index route uses the correct URI scheme
4589debf2c is described below

commit 4589debf2ce5d87ce29342276f5efe479ad1b119
Author: James Netherton <ja...@gmail.com>
AuthorDate: Thu Jun 9 15:49:54 2022 +0100

    Ensure ElasticSearch REST delete index route uses the correct URI scheme
    
    Fixes #3831
---
 .../component/elasticsearch/rest/it/ElasticsearchRestRoutes.java      | 2 +-
 .../component/elasticsearch/rest/it/ElasticSearchTestResource.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/integration-tests/elasticsearch-rest/src/main/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticsearchRestRoutes.java b/integration-tests/elasticsearch-rest/src/main/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticsearchRestRoutes.java
index 222bb05c75..aa804dc339 100644
--- a/integration-tests/elasticsearch-rest/src/main/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticsearchRestRoutes.java
+++ b/integration-tests/elasticsearch-rest/src/main/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticsearchRestRoutes.java
@@ -36,7 +36,7 @@ public class ElasticsearchRestRoutes extends RouteBuilder {
                 .toD("${header.component}://elasticsearch?operation=Delete");
 
         from("direct:deleteIndex")
-                .to("elasticsearch-rest://elasticsearch?operation=DeleteIndex");
+                .toD("${header.component}://elasticsearch?operation=DeleteIndex");
 
         from("direct:exists")
                 .toD("${header.component}://elasticsearch?operation=Exists");
diff --git a/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java b/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java
index 6bf5b31ad4..f878e48d07 100644
--- a/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java
+++ b/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java
@@ -35,14 +35,14 @@ public class ElasticSearchTestResource implements QuarkusTestResourceLifecycleMa
     private static final String ELASTICSEARCH_PASSWORD = "changeme";
     private static final int ELASTICSEARCH_PORT = 9200;
 
-    private GenericContainer container;
+    private GenericContainer<?> container;
 
     @Override
     public Map<String, String> start() {
         LOGGER.info(TestcontainersConfiguration.getInstance().toString());
 
         try {
-            container = new GenericContainer(ELASTICSEARCH_IMAGE)
+            container = new GenericContainer<>(ELASTICSEARCH_IMAGE)
                     .withExposedPorts(ELASTICSEARCH_PORT)
                     .withLogConsumer(new Slf4jLogConsumer(LOGGER))
                     .withEnv("discovery.type", "single-node")