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

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

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...s/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java b/...s/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java
@@ -104,7 +104,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/...-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java b/...-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java
@@ -46,6 +46,7 @@ public Destination getReplyTo() {
             destResolver.destinationReady();
         } catch (InterruptedException e) {
             log.warn("Interrupted while waiting for JMSReplyTo destination refresh", e);
+            Thread.currentThread().interrupt();
         }
         return super.getReplyTo();
     }