CAMEL-20297 camel-jms: do not swallow interrupted exceptions

apache · Jan 10, 2024 · 489cae4 · 489cae4
1 parent b7dc1da
commit 489cae4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...nts/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java b/...nts/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
@@ -113,7 +113,7 @@ public Destination getReplyTo() {
                 log.trace("Waiting for replyTo to be set done");
             }
         } catch (InterruptedException e) {
-            // ignore
+            Thread.currentThread().interrupt();
         }
         return replyTo;
     }

diff --git a/...el-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java b/...el-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
@@ -53,8 +53,9 @@ public Destination getReplyTo() {
         try {
             destResolver.destinationReady();
         } catch (InterruptedException e) {
-            log.warn("Interrupted while waiting for JMSReplyTo destination refresh due to: {}. This exception is ignored.",
+            log.warn("Interrupted while waiting for JMSReplyTo destination refresh due to: {}.",
                     e.getMessage());
+            Thread.currentThread().interrupt();
         }
         return super.getReplyTo();
     }