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

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit e7e6e1eddb0b5670aee2c751acdb3610a21d6e71
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Thu Jan 11 10:03:05 2024 +0100

    CAMEL-20297 camel-azure-servicebus: do not swallow interrupted exceptions
---
 .../org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
 
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
index 9756ca91e7c..d00b30fe8f5 100644
--- 
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
+++ 
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConsumer.java
@@ -195,7 +195,7 @@ public class ServiceBusConsumer extends DefaultConsumer {
             try {
                 Thread.sleep(getConfiguration().getReconnectDelay());
             } catch (InterruptedException e) {
-                // ignore
+                Thread.currentThread().interrupt();
             }
         }
 

Reply via email to