(camel) branch camel-4.4.x updated: CAMEL-20851: Shut down ElasticSearch client sniffer on producer stop (#14440)

[davsclaus]

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

davsclaus pushed a commit to branch camel-4.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-4.4.x by this push:
     new fd24ac0819d CAMEL-20851: Shut down ElasticSearch client sniffer on 
producer stop (#14440)
fd24ac0819d is described below

commit fd24ac0819db438a99271bfdd172dc3169803db6
Author: James Netherton <jamesnether...@users.noreply.github.com>
AuthorDate: Mon Jun 10 13:00:06 2024 +0100

    CAMEL-20851: Shut down ElasticSearch client sniffer on producer stop 
(#14440)
---
 .../rest/client/ElasticsearchRestClientProducer.java              | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-elasticsearch-rest-client/src/main/java/org/apache/camel/component/elasticsearch/rest/client/ElasticsearchRestClientProducer.java
 
b/components/camel-elasticsearch-rest-client/src/main/java/org/apache/camel/component/elasticsearch/rest/client/ElasticsearchRestClientProducer.java
index 053e734df32..bb7781a12c2 100644
--- 
a/components/camel-elasticsearch-rest-client/src/main/java/org/apache/camel/component/elasticsearch/rest/client/ElasticsearchRestClientProducer.java
+++ 
b/components/camel-elasticsearch-rest-client/src/main/java/org/apache/camel/component/elasticsearch/rest/client/ElasticsearchRestClientProducer.java
@@ -66,6 +66,7 @@ public class ElasticsearchRestClientProducer extends 
DefaultAsyncProducer {
     private ElasticsearchRestClientEndpoint endpoint;
     private RestClient restClient;
     private boolean createdRestClient;
+    private Sniffer sniffer;
 
     public ElasticsearchRestClientProducer(ElasticsearchRestClientEndpoint 
endpoint) {
         super(endpoint);
@@ -114,6 +115,11 @@ public class ElasticsearchRestClientProducer extends 
DefaultAsyncProducer {
         super.doStop();
 
         if (createdRestClient && restClient != null) {
+            if (sniffer != null) {
+                IOHelper.close(sniffer);
+                sniffer = null;
+            }
+
             IOHelper.close(restClient);
             restClient = null;
         }
@@ -385,7 +391,7 @@ public class ElasticsearchRestClientProducer extends 
DefaultAsyncProducer {
 
         // initiate Sniffer
         if (this.endpoint.isEnableSniffer()) {
-            Sniffer.builder(restClient)
+            sniffer = Sniffer.builder(restClient)
                     .setSniffIntervalMillis(this.endpoint.getSnifferInterval())
                     
.setSniffAfterFailureDelayMillis(this.endpoint.getSniffAfterFailureDelay())
                     .build();