You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/01/10 09:25:11 UTC
(camel) 02/02: CAMEL-20297 camel-sjms: do not swallow interrupted exceptions
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 d49d680b6e48ea0a345d878113a07ddfdf3ff247
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Jan 10 09:34:15 2024 +0100
CAMEL-20297 camel-sjms: do not swallow interrupted exceptions
---
.../java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java | 2 +-
.../apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java
index 42219a2fb94..18b05d58fa0 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java
@@ -104,7 +104,7 @@ public abstract class ReplyManagerSupport extends ServiceSupport implements Repl
log.trace("Waiting for replyTo to be set done");
}
} catch (InterruptedException e) {
- // ignore
+ Thread.currentThread().interrupt();
}
return replyTo;
}
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java
index eadbd23869f..6c3ce420c1e 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java
@@ -46,6 +46,7 @@ public class TemporaryQueueReplyManager extends ReplyManagerSupport {
destResolver.destinationReady();
} catch (InterruptedException e) {
log.warn("Interrupted while waiting for JMSReplyTo destination refresh", e);
+ Thread.currentThread().interrupt();
}
return super.getReplyTo();
}