diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java index 9a81edc48eac4..88877970b9926 100644 --- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java +++ b/components/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/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java index ec1e0a6117829..2557f14e9e94e 100644 --- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java +++ b/components/camel-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(); } 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 42219a2fb9413..18b05d58fa04b 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 Destination getReplyTo() { 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 eadbd23869f8d..6c3ce420c1e06 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 Destination getReplyTo() { destResolver.destinationReady(); } catch (InterruptedException e) { log.warn("Interrupted while waiting for JMSReplyTo destination refresh", e); + Thread.currentThread().interrupt(); } return super.getReplyTo(); }